PhalaMq¶
Calls¶
force_push_pallet_message¶
See [Pallet::force_push_pallet_message
].
Attributes¶
Name | Type |
---|---|
destination | Vec<u8> |
payload | Vec<u8> |
Python¶
call = substrate.compose_call(
'PhalaMq', 'force_push_pallet_message', {
'destination': 'Bytes',
'payload': 'Bytes',
}
)
push_message¶
See [Pallet::push_message
].
Attributes¶
Name | Type |
---|---|
destination | Vec<u8> |
payload | Vec<u8> |
Python¶
call = substrate.compose_call(
'PhalaMq', 'push_message', {
'destination': 'Bytes',
'payload': 'Bytes',
}
)
sync_offchain_message¶
See [Pallet::sync_offchain_message
].
Attributes¶
Name | Type |
---|---|
signed_message | SignedMessage |
Python¶
call = substrate.compose_call(
'PhalaMq', 'sync_offchain_message', {
'signed_message': {
'message': {
'destination': 'Bytes',
'payload': 'Bytes',
'sender': {
None: None,
'AccountId': 'scale_info::12',
'Cluster': 'scale_info::12',
'Contract': 'scale_info::12',
'Gatekeeper': None,
'MultiLocation': 'Bytes',
'Pallet': 'Bytes',
'Reserved': None,
'Worker': '[u8; 32]',
},
},
'sequence': 'u64',
'signature': 'Bytes',
},
}
)
Storage functions¶
OffchainIngress¶
The next expected sequence of a ingress message coming from a certain sender (origin)
Python¶
result = substrate.query(
'PhalaMq', 'OffchainIngress', [
{
'AccountId': 'scale_info::12',
'Cluster': 'scale_info::12',
'Contract': 'scale_info::12',
'Gatekeeper': None,
'MultiLocation': 'Bytes',
'Pallet': 'Bytes',
'Reserved': None,
'Worker': '[u8; 32]',
None: None,
},
]
)
Return value¶
'u64'
OutboundMessages¶
Outbound messages at the current block.
It will be cleared at the beginning of every block.
Python¶
result = substrate.query(
'PhalaMq', 'OutboundMessages', []
)
Return value¶
[
{
'destination': 'Bytes',
'payload': 'Bytes',
'sender': {
'AccountId': 'scale_info::12',
'Cluster': 'scale_info::12',
'Contract': 'scale_info::12',
'Gatekeeper': None,
'MultiLocation': 'Bytes',
'Pallet': 'Bytes',
'Reserved': None,
'Worker': '[u8; 32]',
None: None,
},
},
]
QueuedOutboundMessage¶
Python¶
result = substrate.query(
'PhalaMq', 'QueuedOutboundMessage', []
)
Return value¶
[
{
'destination': 'Bytes',
'payload': 'Bytes',
'sender': {
'AccountId': 'scale_info::12',
None: None,
'Cluster': 'scale_info::12',
'Contract': 'scale_info::12',
'Gatekeeper': None,
'MultiLocation': 'Bytes',
'Pallet': 'Bytes',
'Reserved': None,
'Worker': '[u8; 32]',
},
},
]