Struct GrpcConnection 

pub struct GrpcConnection { /* private fields */ }

gRPC connection manager for bidirectional streaming

Implementations

impl GrpcConnection

pub fn new(server_address: ServerAddress) -> Self

Create a new gRPC connection

pub fn with_namespace(self, namespace: &str) -> Self

Set namespace

pub fn with_app_name(self, app_name: &str) -> Self

Set app name

pub fn with_labels(self, labels: HashMap<String, String>) -> Self

Set labels

pub fn with_timeout(self, timeout_ms: u64) -> Self

Set timeout

pub fn connection_id(&self) -> String

Get connection ID

pub fn state(&self) -> ConnectionState

Get current state

pub fn is_connected(&self) -> bool

Check if connected

pub fn register_push_handler( &self, message_type: &str, handler: ServerPushHandler, )

Register a push handler for a specific message type

pub async fn connect(&self) -> Result<()>

Connect to server

pub async fn disconnect(&self)

Disconnect from server

pub async fn request<Req, Resp>(&self, request: &Req) -> Result<Resp>

where Req: RequestTrait + Serialize, Resp: for<'de> Deserialize<'de> + Default + ResponseTrait,

Send a request and wait for response

pub async fn send(&self, payload: Payload) -> Result<()>

Send a message through the stream (no response expected)