Struct sp_core::offchain::testing::TestOffchainExt

source · [−]

pub struct TestOffchainExt(pub Arc<RwLock<OffchainState>>);

Expand description

Implementation of offchain externalities used for tests.

Tuple Fields

0: Arc<RwLock<OffchainState>>

Implementations

source

impl TestOffchainExt

source

pub fn new() -> (Self, Arc<RwLock<OffchainState>>)

Create new TestOffchainExt and a reference to the internal state.

source

pub fn with_offchain_db(
offchain_db: TestPersistentOffchainDB
) -> (Self, Arc<RwLock<OffchainState>>)

Create new TestOffchainExt and a reference to the internal state.

Trait Implementations

source

impl Clone for TestOffchainExt

source

fn clone(&self) -> TestOffchainExt

Returns a copy of the value. Read more

1.0.0 · source

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more

source

impl DbExternalities for TestOffchainExt

source

fn local_storage_set(&mut self, kind: StorageKind, key: &[u8 ], value: &[u8 ])

Sets a value in the local storage. Read more

source

fn local_storage_clear(&mut self, kind: StorageKind, key: &[u8 ])

Removes a value in the local storage. Read more

source

fn local_storage_compare_and_set(
 &mut self,
 kind: StorageKind,
 key: &[u8 ],
 old_value: Option<&[u8 ]>,
 new_value: &[u8 ]
) -> bool

Sets a value in the local storage if it matches current value. Read more

source

fn local_storage_get(
 &mut self,
 kind: StorageKind,
 key: &[u8 ]
) -> Option<Vec<u8>>

Gets a value from the local storage. Read more

source

impl Debug for TestOffchainExt

source

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

source

impl Default for TestOffchainExt

source

fn default() -> TestOffchainExt

Returns the “default value” for a type. Read more

source

impl Externalities for TestOffchainExt

source

fn is_validator(&self) -> bool

Returns if the local node is a potential validator. Read more

source

fn network_state(&self) -> Result<OpaqueNetworkState, ()>

Returns information about the local node’s network state.

source

fn timestamp(&mut self) -> Timestamp

Returns current UNIX timestamp (in millis)

source

fn sleep_until(&mut self, deadline: Timestamp)

Pause the execution until deadline is reached.

source

fn random_seed(&mut self) -> [u8 ; 32]

Returns a random seed. Read more

source

fn http_request_start(
 &mut self,
 method: &str,
 uri: &str,
 meta: &[u8 ]
) -> Result<RequestId, ()>

Initiates a http request given HTTP verb and the URL. Read more

source

fn http_request_add_header(
 &mut self,
 request_id: RequestId,
 name: &str,
 value: &str
) -> Result<(), ()>

Append header to the request. Read more

source

fn http_request_write_body(
 &mut self,
 request_id: RequestId,
 chunk: &[u8 ],
 _deadline: Option<Timestamp>
) -> Result<(), HttpError>

Write a chunk of request body. Read more

source

fn http_response_wait(
 &mut self,
 ids: &[RequestId ],
 _deadline: Option<Timestamp>
) -> Vec<RequestStatus>ⓘ
Notable traits for Vec<u8, A>
`impl<A> Write for Vec<u8, A> where A: Allocator,`

Block and wait for the responses for given requests. Read more

source

fn http_response_headers(
 &mut self,
 request_id: RequestId
) -> Vec<(Vec<u8>, Vec<u8>)>ⓘ
Notable traits for Vec<u8, A>
`impl<A> Write for Vec<u8, A> where A: Allocator,`

Read all response headers. Read more

source

fn http_response_read_body(
 &mut self,
 request_id: RequestId,
 buffer: &mut [u8 ],
 _deadline: Option<Timestamp>
) -> Result<usize, HttpError>

Read a chunk of body response to given buffer. Read more

source

fn set_authorized_nodes(
 &mut self,
 _nodes: Vec<OpaquePeerId>,
 _authorized_only: bool
)

Set the authorized nodes from runtime. Read more

Auto Trait Implementations

impl !RefUnwindSafe for TestOffchainExt

impl Send for TestOffchainExt

impl Sync for TestOffchainExt

impl Unpin for TestOffchainExt

impl !UnwindSafe for TestOffchainExt

Blanket Implementations

source

impl<T> Any for T where
T: 'static + ?Sized,

source

pub fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

source

impl<T> Borrow<T> for T where
T: ?Sized,

const: unstable · source

pub fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source

impl<T> BorrowMut<T> for T where
T: ?Sized,

const: unstable · source

pub fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

source

impl<T> Downcast for T where
T: Any,

source

pub fn into_any(self: Box<T, Global>) -> Box<dyn Any + 'static, Global>

Convert Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can then be further downcast into Box<ConcreteType> where ConcreteType implements Trait. Read more

source

pub fn into_any_rc(self: Rc<T>) -> Rc<dyn Any + 'static>

Convert Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be further downcast into Rc<ConcreteType> where ConcreteType implements Trait. Read more

source

pub fn as_any(&self) -> &(dyn Any + 'static)

Convert &Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &Any’s vtable from &Trait’s. Read more

source

pub fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Convert &mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot generate &mut Any’s vtable from &mut Trait’s. Read more

source

impl<T> DowncastSync for T where
T: Any + Send + Sync,

source

pub fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Sync + Send + 'static>

Convert Arc<Trait> (where Trait: Downcast) to Arc<Any>. Arc<Any> can then be further downcast into Arc<ConcreteType> where ConcreteType implements Trait. Read more

source

pub fn from(t: T) -> T

Performs the conversion.

source

impl<T> Instrument for T

source

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

source

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

source

impl<T, U> Into for T where
U: From<T>,

const: unstable · source

pub fn into(self) -> U

Performs the conversion.

source

impl<T, Outer> IsWrappedBy<Outer> for T where
Outer: AsRef<T> + AsMut<T> + From<T>,
T: From<Outer>,

source

fn from_ref(outer: &Outer) -> &Self

Get a reference to the inner from the outer.

source

fn from_mut(outer: &mut Outer) -> &mut Self

Get a mutable reference to the inner from the outer.

source

impl<T> Same<T> for T

type Output = T

Should always be Self

source

impl<T> ToOwned for T where
T: Clone,

type Owned = T

The resulting type after obtaining ownership.

source

pub fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

source

pub fn clone_into(&self, target: &mut T)

🔬 This is a nightly-only experimental API. (toowned_clone_into)

Uses borrowed data to replace owned data, usually by cloning. Read more

source

impl<T, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source

impl<T, U> TryInto for T where
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

source

impl<S, T> UncheckedInto<T> for S where
T: UncheckedFrom<S>,

source

fn unchecked_into(self) -> T

The counterpart to unchecked_from.

source

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

source

pub fn vzip(self) -> V

source

impl<T> WithSubscriber for T

source

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

source

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

source

impl<T> MaybeDebug for T where
T: Debug,

source

Struct sp_core::offchain::testing::TestOffchainExt

Tuple Fields

Implementations

impl TestOffchainExt

pub fn new() -> (Self, Arc<RwLock<OffchainState>>)

pub fn with_offchain_db( offchain_db: TestPersistentOffchainDB) -> (Self, Arc<RwLock<OffchainState>>)

Trait Implementations

impl Clone for TestOffchainExt

fn clone(&self) -> TestOffchainExt

fn clone_from(&mut self, source: &Self)

impl DbExternalities for TestOffchainExt

fn local_storage_set(&mut self, kind: StorageKind, key: &[u8], value: &[u8])

fn local_storage_clear(&mut self, kind: StorageKind, key: &[u8])

fn local_storage_compare_and_set( &mut self, kind: StorageKind, key: &[u8], old_value: Option<&[u8]>, new_value: &[u8]) -> bool

fn local_storage_get( &mut self, kind: StorageKind, key: &[u8]) -> Option<Vec<u8>>

impl Debug for TestOffchainExt

fn fmt(&self, f: &mut Formatter<'_>) -> Result

impl Default for TestOffchainExt

fn default() -> TestOffchainExt

impl Externalities for TestOffchainExt

fn is_validator(&self) -> bool

fn network_state(&self) -> Result<OpaqueNetworkState, ()>

fn timestamp(&mut self) -> Timestamp

fn sleep_until(&mut self, deadline: Timestamp)

fn random_seed(&mut self) -> [u8; 32]

fn http_request_start( &mut self, method: &str, uri: &str, meta: &[u8]) -> Result<RequestId, ()>

fn http_request_add_header( &mut self, request_id: RequestId, name: &str, value: &str) -> Result<(), ()>

fn http_request_write_body( &mut self, request_id: RequestId, chunk: &[u8], _deadline: Option<Timestamp>) -> Result<(), HttpError>

fn http_response_wait( &mut self, ids: &[RequestId], _deadline: Option<Timestamp>) -> Vec<RequestStatus>ⓘNotable traits for Vec<u8, A>impl<A> Write for Vec<u8, A> where A: Allocator,

fn http_response_headers( &mut self, request_id: RequestId) -> Vec<(Vec<u8>, Vec<u8>)>ⓘNotable traits for Vec<u8, A>impl<A> Write for Vec<u8, A> where A: Allocator,

fn http_response_read_body( &mut self, request_id: RequestId, buffer: &mut [u8], _deadline: Option<Timestamp>) -> Result<usize, HttpError>

fn set_authorized_nodes( &mut self, _nodes: Vec<OpaquePeerId>, _authorized_only: bool)

Auto Trait Implementations

impl !RefUnwindSafe for TestOffchainExt

impl Send for TestOffchainExt

impl Sync for TestOffchainExt

impl Unpin for TestOffchainExt

impl !UnwindSafe for TestOffchainExt

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where T: ?Sized,

pub fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

pub fn borrow_mut(&mut self) -> &mut T

impl<T> Downcast for T where T: Any,

pub fn into_any(self: Box<T, Global>) -> Box<dyn Any + 'static, Global>

pub fn into_any_rc(self: Rc<T>) -> Rc<dyn Any + 'static>

pub fn as_any(&self) -> &(dyn Any + 'static)

pub fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

impl<T> DowncastSync for T where T: Any + Send + Sync,

pub fn into_any_arc(self: Arc<T>) -> Arc<dyn Any + Sync + Send + 'static>

impl<T> DynClone for T where T: Clone,

pub fn __clone_box(&self, Private) -> *mut ()

impl<T> From<T> for T

pub fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for T where U: From<T>,

pub fn into(self) -> U

impl<T, Outer> IsWrappedBy<Outer> for T where Outer: AsRef<T> + AsMut<T> + From<T>, T: From<Outer>,

fn from_ref(outer: &Outer) -> &Self

fn from_mut(outer: &mut Outer) -> &mut Self

impl<T> Same<T> for T

type Output = T

impl<T> ToOwned for T where T: Clone,

type Owned = T

pub fn to_owned(&self) -> T

pub fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<S, T> UncheckedInto<T> for S where T: UncheckedFrom<S>,

fn unchecked_into(self) -> T

impl<V, T> VZip<V> for T where V: MultiLane<T>,

pub fn vzip(self) -> V

pub fn with_offchain_db(
offchain_db: TestPersistentOffchainDB
) -> (Self, Arc<RwLock<OffchainState>>)

fn local_storage_set(&mut self, kind: StorageKind, key: &[u8 ], value: &[u8 ])

fn local_storage_clear(&mut self, kind: StorageKind, key: &[u8 ])

fn local_storage_compare_and_set(
&mut self,
kind: StorageKind,
key: &[u8 ],
old_value: Option<&[u8 ]>,
new_value: &[u8 ]
) -> bool

fn local_storage_get(
&mut self,
kind: StorageKind,
key: &[u8 ]
) -> Option<Vec<u8>>

fn random_seed(&mut self) -> [u8 ; 32]

fn http_request_start(
&mut self,
method: &str,
uri: &str,
meta: &[u8 ]
) -> Result<RequestId, ()>

fn http_request_add_header(
&mut self,
request_id: RequestId,
name: &str,
value: &str
) -> Result<(), ()>

fn http_request_write_body(
&mut self,
request_id: RequestId,
chunk: &[u8 ],
_deadline: Option<Timestamp>
) -> Result<(), HttpError>

fn http_response_wait(
&mut self,
ids: &[RequestId ],
_deadline: Option<Timestamp>
) -> Vec<RequestStatus>ⓘ
Notable traits for Vec<u8, A>
`impl<A> Write for Vec<u8, A> where A: Allocator,`

fn http_response_headers(
&mut self,
request_id: RequestId
) -> Vec<(Vec<u8>, Vec<u8>)>ⓘ
Notable traits for Vec<u8, A>
`impl<A> Write for Vec<u8, A> where A: Allocator,`

fn http_response_read_body(
&mut self,
request_id: RequestId,
buffer: &mut [u8 ],
_deadline: Option<Timestamp>
) -> Result<usize, HttpError>

fn set_authorized_nodes(
&mut self,
_nodes: Vec<OpaquePeerId>,
_authorized_only: bool
)

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<T> Downcast for T where
T: Any,

impl<T> DowncastSync for T where
T: Any + Send + Sync,

impl<T> DynClone for T where
T: Clone,

impl<T, U> Into<U> for T where
U: From<T>,

impl<T, Outer> IsWrappedBy<Outer> for T where
Outer: AsRef<T> + AsMut<T> + From<T>,
T: From<Outer>,

impl<T> ToOwned for T where
T: Clone,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

impl<S, T> UncheckedInto<T> for S where
T: UncheckedFrom<S>,

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,

impl<T> MaybeDebug for T where
T: Debug,

impl<T> MaybeRefUnwindSafe for T where
T: RefUnwindSafe,