Enum Command 

pub enum Command {
    Hello,
    Configure {
        endpoint: String,
        bearer: Option<String>,
    },
    Publish {
        topic: String,
        value_b64: String,
        headers: Vec<Header>,
    },
    PublishEvent {
        topic: String,
        event: CloudEvent,
    },
    Subscribe {
        topics: Vec<String>,
        group: String,
        filter: Option<Filter>,
    },
    NextMessage {
        timeout_ms: u64,
    },
    QueueAcquire {
        topic: String,
        group: String,
        max: u32,
        lock_duration_ms: u64,
        session_id: String,
    },
    QueueAck {
        message_id: String,
    },
    QueueAcknowledge {
        session_id: String,
        entries: Vec<QueueAckEntry>,
    },
    QueueRenew {
        session_id: String,
        entries: Vec<QueueRenewEntry>,
    },
    DbConnect {
        name: String,
    },
    AuthSignIn {
        username: String,
        password: String,
    },
    BlobPut {
        key: String,
        value_b64: String,
    },
    BlobGet {
        key: String,
    },
}

A command sent from the conformance harness to a language adapter.

Variants

Hello

Negotiate the contract major and adapter language.

Configure

Configure the SDK endpoint and optional bearer token.

Fields

endpoint: String

Gateway endpoint URL.

bearer: Option<String>

Optional bearer token to forward through the SDK.

Publish

Publish a raw record.

Fields

topic: String

Topic name.

value_b64: String

Base64-encoded record value.

headers: Vec<Header>

Binary headers in publish order.

PublishEvent

Publish a CloudEvent in binary mode.

Fields

topic: String

Topic name.

event: CloudEvent

CloudEvent payload and attributes.

Subscribe

Open or replace a subscription.

Fields

topics: Vec<String>

Topics to subscribe to.

group: String

Consumer group id.

filter: Option<Filter>

Optional structured equality filter.

NextMessage

Pull the next message from the active subscription.

Fields

timeout_ms: u64

Maximum wait time in milliseconds.

QueueAcquire

Queue acquire stub command.

Fields

topic: String

Topic/queue name.

group: String

Worker group id.

max: u32

Maximum number of messages.

lock_duration_ms: u64

Lock duration in milliseconds.

session_id: String

Optional session id returned by a prior acquire.

QueueAck

Queue ack stub command kept in the v1.0 stub-vector group.

Fields

message_id: String

Message id to ack.

QueueAcknowledge

Queue acknowledge command for the v1.1 queue RPC contract group.

Fields

session_id: String

Session id returned by queue acquire.

entries: Vec<QueueAckEntry>

Entries to acknowledge.

QueueRenew

Queue renew command for the v1.1 queue RPC contract group.

Fields

session_id: String

Session id returned by queue acquire.

entries: Vec<QueueRenewEntry>

Entries to renew.

DbConnect

Database connect stub command.

Fields

name: String

Database name.

AuthSignIn

Auth sign-in placeholder command.

Fields

username: String

Username.

password: String

Password.

BlobPut

Blob put stub command.

Fields

key: String

Blob key.

value_b64: String

Base64-encoded blob body.

BlobGet

Blob get stub command.

Fields

key: String

Blob key.

Trait Implementations

impl Clone for Command

fn clone(&self) -> Command

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Command

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Command

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Command

fn eq(&self, other: &Command) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for Command

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Command