agentcommunicationpb

type AgentCommunicationClient interface {
	// Bi-di streaming between the server and resource on a communication channel.
	StreamAgentMessages(ctx context.Context, opts ...grpc.CallOption) (AgentCommunication_StreamAgentMessagesClient, error)
}

type AgentCommunicationServer interface {
	// Bi-di streaming between the server and resource on a communication channel.
	StreamAgentMessages(AgentCommunication_StreamAgentMessagesServer) error
}

type AgentCommunication_StreamAgentMessagesClient interface {
	Send(*StreamAgentMessagesRequest) error
	Recv() (*StreamAgentMessagesResponse, error)
	grpc.ClientStream
}

type AgentCommunication_StreamAgentMessagesServer interface {
	Send(*StreamAgentMessagesResponse) error
	Recv() (*StreamAgentMessagesRequest, error)
	grpc.ServerStream
}

type ErrorReason int32

type MessageBody struct {

	// Labels to use for this message for easy lookup and client side filtering.
	// Labels must meet the following constraints:
	//
	// * Keys and values can contain only lowercase letters, numeric characters,
	// underscores, and dashes.
	// * All characters must use UTF-8 encoding, and international characters are
	// allowed.
	// * Keys must start with a lowercase letter or international character.
	// * Each message is limited to a maximum of 12 labels and less than 1024
	// bytes.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Required. The actual message.
	Body *anypb.Any `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type MessageResponse struct {

	// Status for this message response, for non OK status ErrorInfo.reason will
	// be one of StreamAgentMessagesResponse.ErrorReason.
	// Expected agent responses:
	// OK - message was successfully received.
	// Expected service responses:
	// OK - message was successfully received.
	// RESOURCE_EXHAUSTED - this connection is rate limited, message delivery
	// should be slowed.
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type RegisterConnection struct {

	// Required. Protocol version to use.
	ProtocolVersion int32 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	// Required. ID of the channel for the connection.
	// The channel ID must:
	//  - Be 1-63 characters in length.
	//  - Match the regular expression ^[a-z]([-a-z0-9]*[a-z0-9])?$. This means
	//  that the first character must be a lowercase letter, and all the following
	//  characters must be hyphens, lowercase letters, or digits, except the last
	//  character, which cannot be a hyphen.
	ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	// Required. ID of the resource for the connection.
	// This must only contain UTF-8 encoded characters and be 1-255 characters in
	// length.
	ResourceId string `protobuf:"bytes,3,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	// contains filtered or unexported fields
}

type StreamAgentMessagesRequest struct {

	// Required. The ID of the message sent to the service, this ID is used to
	// uniquely identify this message so service can ack.
	MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// Types that are assignable to Type:
	//	*StreamAgentMessagesRequest_RegisterConnection
	//	*StreamAgentMessagesRequest_MessageResponse
	//	*StreamAgentMessagesRequest_MessageBody
	Type isStreamAgentMessagesRequest_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type StreamAgentMessagesRequest_MessageBody struct {
	// A message meant for a client.
	MessageBody *MessageBody `protobuf:"bytes,4,opt,name=message_body,json=messageBody,proto3,oneof"`
}

type StreamAgentMessagesRequest_MessageResponse struct {
	// Response to a message sent from the service.
	// Should be sent as soon as the agent receives a message.
	MessageResponse *MessageResponse `protobuf:"bytes,3,opt,name=message_response,json=messageResponse,proto3,oneof"`
}

type StreamAgentMessagesRequest_RegisterConnection struct {
	// Initial stream message. Must be sent before any other messages on this
	// stream.
	RegisterConnection *RegisterConnection `protobuf:"bytes,2,opt,name=register_connection,json=registerConnection,proto3,oneof"`
}

type StreamAgentMessagesResponse struct {

	// The ID of the message sent to the agent, this ID is used to uniquely
	// identify this message so agent can ack.
	MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// Types that are assignable to Type:
	//	*StreamAgentMessagesResponse_MessageResponse
	//	*StreamAgentMessagesResponse_MessageBody
	Type isStreamAgentMessagesResponse_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type StreamAgentMessagesResponse_ErrorReason int32

type StreamAgentMessagesResponse_MessageBody struct {
	// A message sent from a client.
	MessageBody *MessageBody `protobuf:"bytes,3,opt,name=message_body,json=messageBody,proto3,oneof"`
}

type StreamAgentMessagesResponse_MessageResponse struct {
	// Response to a message sent to the service.
	// Will be sent as soon as the service receives a message.
	MessageResponse *MessageResponse `protobuf:"bytes,2,opt,name=message_response,json=messageResponse,proto3,oneof"`
}

type UnimplementedAgentCommunicationServer struct {
}