Trait solana_core::rpc_pubsub::RpcSolPubSub[−][src]

pub trait RpcSolPubSub: Sized + Send + Sync + 'static {
    type Metadata: PubSubMetadata;
    fn account_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<RpcResponse<UiAccount>>, 
        pubkey_str: String, 
        config: Option<RpcAccountInfoConfig>
    );

    fn account_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: SubscriptionId
    ) -> Result<bool>;

    fn program_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<RpcResponse<RpcKeyedAccount>>, 
        pubkey_str: String, 
        config: Option<RpcProgramAccountsConfig>
    );

    fn program_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: SubscriptionId
    ) -> Result<bool>;

    fn logs_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<RpcResponse<RpcLogsResponse>>, 
        filter: RpcTransactionLogsFilter, 
        config: Option<RpcTransactionLogsConfig>
    );

    fn logs_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: SubscriptionId
    ) -> Result<bool>;

    fn signature_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<RpcResponse<RpcSignatureResult>>, 
        signature_str: String, 
        config: Option<RpcSignatureSubscribeConfig>
    );

    fn signature_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: SubscriptionId
    ) -> Result<bool>;

    fn slot_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<SlotInfo>
    );

    fn slot_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: SubscriptionId
    ) -> Result<bool>;

    fn slots_updates_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<Arc<SlotUpdate>>
    );

    fn slots_updates_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: SubscriptionId
    ) -> Result<bool>;

    fn vote_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<RpcVote>
    );

    fn vote_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: SubscriptionId
    ) -> Result<bool>;

    fn root_subscribe(&self, meta: Self::Metadata, subscriber: Subscriber<Slot>);

    fn root_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: SubscriptionId
    ) -> Result<bool>;

    fn eth_subscribe(
        &self, 
        meta: Self::Metadata, 
        subscriber: Subscriber<RPCBlock>, 
        topic: String, 
        anydata: Option<Value>
    );

    fn eth_unsubscribe(
        &self, 
        meta: Option<Self::Metadata>, 
        id: SubscriptionId
    ) -> Result<bool>;

    fn to_delegate(self) -> IoDelegate<Self, Self::Metadata> { ... }
}

Associated Types

type Metadata: PubSubMetadata[src]

Loading content...

Required methods

fn account_subscribe(
    &self,
    meta: Self::Metadata,
    subscriber: Subscriber<RpcResponse<UiAccount>>,
    pubkey_str: String,
    config: Option<RpcAccountInfoConfig>
)[src]

fn account_unsubscribe(
    &self,
    meta: Option<Self::Metadata>,
    id: SubscriptionId
) -> Result<bool>[src]

fn program_subscribe(
    &self,
    meta: Self::Metadata,
    subscriber: Subscriber<RpcResponse<RpcKeyedAccount>>,
    pubkey_str: String,
    config: Option<RpcProgramAccountsConfig>
)[src]

fn program_unsubscribe(
    &self,
    meta: Option<Self::Metadata>,
    id: SubscriptionId
) -> Result<bool>[src]

fn logs_subscribe(
    &self,
    meta: Self::Metadata,
    subscriber: Subscriber<RpcResponse<RpcLogsResponse>>,
    filter: RpcTransactionLogsFilter,
    config: Option<RpcTransactionLogsConfig>
)[src]

fn logs_unsubscribe(
    &self,
    meta: Option<Self::Metadata>,
    id: SubscriptionId
) -> Result<bool>[src]

fn signature_subscribe(
    &self,
    meta: Self::Metadata,
    subscriber: Subscriber<RpcResponse<RpcSignatureResult>>,
    signature_str: String,
    config: Option<RpcSignatureSubscribeConfig>
)[src]

fn signature_unsubscribe(
    &self,
    meta: Option<Self::Metadata>,
    id: SubscriptionId
) -> Result<bool>[src]

fn slot_subscribe(&self, meta: Self::Metadata, subscriber: Subscriber<SlotInfo>)[src]

fn slot_unsubscribe(
    &self,
    meta: Option<Self::Metadata>,
    id: SubscriptionId
) -> Result<bool>[src]

fn slots_updates_subscribe(
    &self,
    meta: Self::Metadata,
    subscriber: Subscriber<Arc<SlotUpdate>>
)[src]

fn slots_updates_unsubscribe(
    &self,
    meta: Option<Self::Metadata>,
    id: SubscriptionId
) -> Result<bool>[src]

fn vote_subscribe(&self, meta: Self::Metadata, subscriber: Subscriber<RpcVote>)[src]

fn vote_unsubscribe(
    &self,
    meta: Option<Self::Metadata>,
    id: SubscriptionId
) -> Result<bool>[src]

fn root_subscribe(&self, meta: Self::Metadata, subscriber: Subscriber<Slot>)[src]

fn root_unsubscribe(
    &self,
    meta: Option<Self::Metadata>,
    id: SubscriptionId
) -> Result<bool>[src]

fn eth_subscribe(
    &self,
    meta: Self::Metadata,
    subscriber: Subscriber<RPCBlock>,
    topic: String,
    anydata: Option<Value>
)[src]

fn eth_unsubscribe(
    &self,
    meta: Option<Self::Metadata>,
    id: SubscriptionId
) -> Result<bool>[src]

Loading content...

Provided methods

fn to_delegate(self) -> IoDelegate<Self, Self::Metadata>[src]

Create an IoDelegate, wiring rpc calls to the trait methods.

Loading content...

Implementors

impl RpcSolPubSub for RpcSolPubSubImpl[src]

type Metadata = Arc<Session>

Loading content...