Struct AgentServiceClient 

pub struct AgentServiceClient<T> { /* private fields */ }

Implementations

impl<T> AgentServiceClient<T>

where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn with_interceptor<F>( inner: T, interceptor: F, ) -> AgentServiceClient<InterceptedService<T, F>>

where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing responses.

pub fn max_decoding_message_size(self, limit: usize) -> Self

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> Self

Limits the maximum size of an encoded message.

Default: usize::MAX

pub async fn connect( &mut self, request: impl IntoRequest<ConnectRequest>, ) -> Result<Response<ConnectResponse>, Status>

pub async fn context( &mut self, request: impl IntoRequest<ContextRequest>, ) -> Result<Response<ContextResponse>, Status>

pub async fn submit( &mut self, request: impl IntoRequest<SubmitRequest>, ) -> Result<Response<SubmitResponse>, Status>

pub async fn verify( &mut self, request: impl IntoRequest<VerifyRequest>, ) -> Result<Response<Streaming<VerifyStepResult>>, Status>

Trigger verification pipeline on a changeset (server-streaming)

pub async fn merge( &mut self, request: impl IntoRequest<MergeRequest>, ) -> Result<Response<MergeResponse>, Status>

Merge an approved changeset into a Git commit

pub async fn watch( &mut self, request: impl IntoRequest<WatchRequest>, ) -> Result<Response<Streaming<WatchEvent>>, Status>

Watch for repo events from other agents (server-streaming)

pub async fn file_read( &mut self, request: impl IntoRequest<FileReadRequest>, ) -> Result<Response<FileReadResponse>, Status>

File-level operations through the session workspace overlay

pub async fn file_write( &mut self, request: impl IntoRequest<FileWriteRequest>, ) -> Result<Response<FileWriteResponse>, Status>

pub async fn file_list( &mut self, request: impl IntoRequest<FileListRequest>, ) -> Result<Response<FileListResponse>, Status>

pub async fn pre_submit_check( &mut self, request: impl IntoRequest<PreSubmitCheckRequest>, ) -> Result<Response<PreSubmitCheckResponse>, Status>

Dry-run conflict detection before SUBMIT

pub async fn get_session_status( &mut self, request: impl IntoRequest<SessionStatusRequest>, ) -> Result<Response<SessionStatusResponse>, Status>

Get current session workspace state

pub async fn push( &mut self, request: impl IntoRequest<PushRequest>, ) -> Result<Response<PushResponse>, Status>

Push merged changes to GitHub (branch or PR)

pub async fn approve( &mut self, request: impl IntoRequest<ApproveRequest>, ) -> Result<Response<ApproveResponse>, Status>

Approve a submitted changeset (platform-level state transition)

Trait Implementations

impl<T: Clone> Clone for AgentServiceClient<T>

fn clone(&self) -> AgentServiceClient<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for AgentServiceClient<T>

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

Formats the value using the given formatter.