Enum RequestPayload 

pub enum RequestPayload {
    Handshake {
        module_id: String,
        module_name: String,
        version: String,
    },
    GetBlock {
        hash: [u8; 32],
    },
    GetBlockHeader {
        hash: [u8; 32],
    },
    GetTransaction {
        hash: [u8; 32],
    },
    HasTransaction {
        hash: [u8; 32],
    },
    GetChainTip,
    GetBlockHeight,
    GetUtxo {
        outpoint: OutPoint,
    },
    SubscribeEvents {
        event_types: Vec<EventType>,
    },
    GetMempoolTransactions,
    GetMempoolTransaction {
        tx_hash: [u8; 32],
    },
    GetMempoolSize,
    GetNetworkStats,
    GetNetworkPeers,
    GetChainInfo,
    GetBlockByHeight {
        height: u64,
    },
    GetLightningNodeUrl,
    GetLightningInfo,
    GetPaymentState {
        payment_id: String,
    },
    CheckTransactionInMempool {
        tx_hash: [u8; 32],
    },
    GetFeeEstimate {
        target_blocks: u32,
    },
    ReadFile {
        path: String,
    },
    WriteFile {
        path: String,
        data: Vec<u8>,
    },
    DeleteFile {
        path: String,
    },
    ListDirectory {
        path: String,
    },
    CreateDirectory {
        path: String,
    },
    GetFileMetadata {
        path: String,
    },
    RegisterRpcEndpoint {
        method: String,
        description: String,
    },
    UnregisterRpcEndpoint {
        method: String,
    },
    RegisterTimer {
        interval_seconds: u64,
    },
    CancelTimer {
        timer_id: u64,
    },
    ScheduleTask {
        delay_seconds: u64,
    },
    ReportMetric {
        metric: Metric,
    },
    GetModuleMetrics {
        module_id: String,
    },
    GetAllMetrics,
    DiscoverModules,
    GetModuleInfo {
        module_id: String,
    },
    IsModuleAvailable {
        module_id: String,
    },
    PublishEvent {
        event_type: EventType,
        payload: EventPayload,
    },
    CallModule {
        target_module_id: Option<String>,
        method: String,
        params: Vec<u8>,
    },
    RegisterModuleApi {
        methods: Vec<String>,
        api_version: u32,
    },
    UnregisterModuleApi,
    GetModuleHealth {
        module_id: String,
    },
    GetAllModuleHealth,
    ReportModuleHealth {
        health: ModuleHealth,
    },
    SendMeshPacketToPeer {
        peer_addr: String,
        packet_data: Vec<u8>,
    },
    SendStratumV2MessageToPeer {
        peer_addr: String,
        message_data: Vec<u8>,
    },
    GetBlockTemplate {
        rules: Vec<String>,
        coinbase_script: Option<Vec<u8>>,
        coinbase_address: Option<String>,
    },
    SubmitBlock {
        block: Block,
    },
    MergeBlockServeDenylist {
        block_hashes: Vec<[u8; 32]>,
    },
    GetBlockServeDenylistSnapshot,
    ClearBlockServeDenylist,
    ReplaceBlockServeDenylist {
        block_hashes: Vec<[u8; 32]>,
    },
    MergeTxServeDenylist {
        tx_hashes: Vec<[u8; 32]>,
    },
    GetTxServeDenylistSnapshot,
    ClearTxServeDenylist,
    ReplaceTxServeDenylist {
        tx_hashes: Vec<[u8; 32]>,
    },
    GetSyncStatus,
    BanPeer {
        peer_addr: String,
        ban_duration_seconds: Option<u64>,
    },
    SetBlockServeMaintenanceMode {
        enabled: bool,
    },
    RegisterCliSpec {
        spec: CliSpec,
    },
}

Request payload types

Variants

Handshake

Handshake: Module identifies itself (first message)

Fields

module_id: String

module_name: String

version: String

GetBlock

Fields

hash: [u8; 32]

GetBlockHeader

Fields

hash: [u8; 32]

GetTransaction

Fields

hash: [u8; 32]

HasTransaction

Fields

hash: [u8; 32]

GetChainTip

GetBlockHeight

GetUtxo

Fields

outpoint: OutPoint

SubscribeEvents

Fields

event_types: Vec<EventType>

GetMempoolTransactions

GetMempoolTransaction

Fields

tx_hash: [u8; 32]

GetMempoolSize

GetNetworkStats

GetNetworkPeers

GetChainInfo

GetBlockByHeight

Fields

height: u64

GetLightningNodeUrl

GetLightningInfo

GetPaymentState

Fields

payment_id: String

CheckTransactionInMempool

Fields

tx_hash: [u8; 32]

GetFeeEstimate

Fields

target_blocks: u32

ReadFile

Fields

path: String

WriteFile

Fields

path: String

data: Vec<u8>

DeleteFile

Fields

path: String

ListDirectory

Fields

path: String

CreateDirectory

Fields

path: String

GetFileMetadata

Fields

path: String

RegisterRpcEndpoint

Fields

method: String

description: String

UnregisterRpcEndpoint

Fields

method: String

RegisterTimer

Fields

interval_seconds: u64

CancelTimer

Fields

timer_id: u64

ScheduleTask

Fields

delay_seconds: u64

ReportMetric

Fields

metric: Metric

GetModuleMetrics

Fields

module_id: String

GetAllMetrics

DiscoverModules

GetModuleInfo

Fields

module_id: String

IsModuleAvailable

Fields

module_id: String

PublishEvent

Fields

event_type: EventType

payload: EventPayload

CallModule

Fields

target_module_id: Option<String>

method: String

params: Vec<u8>

RegisterModuleApi

Fields

methods: Vec<String>

api_version: u32

UnregisterModuleApi

GetModuleHealth

Fields

module_id: String

GetAllModuleHealth

ReportModuleHealth

Fields

health: ModuleHealth

SendMeshPacketToPeer

Fields

peer_addr: String

packet_data: Vec<u8>

SendStratumV2MessageToPeer

Fields

peer_addr: String

message_data: Vec<u8>

GetBlockTemplate

Fields

rules: Vec<String>

coinbase_script: Option<Vec<u8>>

coinbase_address: Option<String>

SubmitBlock

Fields

block: Block

MergeBlockServeDenylist

Block hashes that must not be answered with a full block on the wire (e.g. getdata).

Fields

block_hashes: Vec<[u8; 32]>

GetBlockServeDenylistSnapshot

ClearBlockServeDenylist

ReplaceBlockServeDenylist

Fields

block_hashes: Vec<[u8; 32]>

MergeTxServeDenylist

Fields

tx_hashes: Vec<[u8; 32]>

GetTxServeDenylistSnapshot

ClearTxServeDenylist

ReplaceTxServeDenylist

Fields

tx_hashes: Vec<[u8; 32]>

GetSyncStatus

BanPeer

Fields

peer_addr: String

ban_duration_seconds: Option<u64>

SetBlockServeMaintenanceMode

Fields

enabled: bool

RegisterCliSpec

Register CLI spec (module → node on connect)

Fields

spec: CliSpec

Trait Implementations

impl Clone for RequestPayload

fn clone(&self) -> RequestPayload

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RequestPayload

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RequestPayload

fn deserialize<__D>( __deserializer: __D, ) -> Result<RequestPayload, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RequestPayload

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.