internal

type Channel struct {
	Channel string `protobuf:"bytes,3,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

type ClaimRequest struct {
	RequestId string  `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	ServerId  string  `protobuf:"bytes,2,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	Affinity  float32 `protobuf:"fixed32,3,opt,name=affinity,proto3" json:"affinity,omitempty"`
	// Handling has begun and no ClaimResponse is awaited. Announced so the caller
	// can tell a slow handler from a request nobody received.
	Handling bool `protobuf:"varint,4,opt,name=handling,proto3" json:"handling,omitempty"`
	// contains filtered or unexported fields
}

type ClaimResponse struct {
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	ServerId  string `protobuf:"bytes,2,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	// contains filtered or unexported fields
}

type Compression int32

type Content struct {
	TypeUrl     string      `protobuf:"bytes,1,opt,name=type_url,json=typeUrl,proto3" json:"type_url,omitempty"`
	Value       []byte      `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Compression Compression `protobuf:"varint,4,opt,name=compression,proto3,enum=internal.Compression" json:"compression,omitempty"`
	// contains filtered or unexported fields
}

type Msg struct {
	TypeUrl string `protobuf:"bytes,1,opt,name=type_url,json=typeUrl,proto3" json:"type_url,omitempty"`
	Value   []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Channel string `protobuf:"bytes,3,opt,name=channel,proto3" json:"channel,omitempty"`
	// Encoding of value.
	Compression Compression `protobuf:"varint,4,opt,name=compression,proto3,enum=internal.Compression" json:"compression,omitempty"`
	// contains filtered or unexported fields
}

type Request struct {
	RequestId  string            `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	ClientId   string            `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	SentAt     int64             `protobuf:"varint,3,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
	Expiry     int64             `protobuf:"varint,4,opt,name=expiry,proto3" json:"expiry,omitempty"`
	Multi      bool              `protobuf:"varint,5,opt,name=multi,proto3" json:"multi,omitempty"`
	Request    *anypb.Any        `protobuf:"bytes,6,opt,name=request,proto3" json:"request,omitempty"`
	Metadata   map[string]string `` /* 143-byte string literal not displayed */
	RawRequest []byte            `protobuf:"bytes,8,opt,name=raw_request,json=rawRequest,proto3" json:"raw_request,omitempty"`
	// Advertises that an announcement may replace the claim; the server decides.
	SkipClaim bool `protobuf:"varint,10,opt,name=skip_claim,json=skipClaim,proto3" json:"skip_claim,omitempty"`
	// contains filtered or unexported fields
}

type Response struct {
	RequestId    string       `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	ServerId     string       `protobuf:"bytes,2,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	SentAt       int64        `protobuf:"varint,3,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
	Response     *anypb.Any   `protobuf:"bytes,4,opt,name=response,proto3" json:"response,omitempty"`
	Error        string       `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	Code         string       `protobuf:"bytes,6,opt,name=code,proto3" json:"code,omitempty"`
	RawResponse  []byte       `protobuf:"bytes,7,opt,name=raw_response,json=rawResponse,proto3" json:"raw_response,omitempty"`
	ErrorDetails []*anypb.Any `protobuf:"bytes,8,rep,name=error_details,json=errorDetails,proto3" json:"error_details,omitempty"`
	// contains filtered or unexported fields
}

type Stream struct {
	StreamId  string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	SentAt    int64  `protobuf:"varint,3,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
	Expiry    int64  `protobuf:"varint,4,opt,name=expiry,proto3" json:"expiry,omitempty"`
	// Types that are valid to be assigned to Body:
	//
	//	*Stream_Open
	//	*Stream_Message
	//	*Stream_Ack
	//	*Stream_Close
	Body isStream_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

type StreamAck struct {
	// contains filtered or unexported fields
}

type StreamClose struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Code  string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

type StreamMessage struct {
	Message    *anypb.Any `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	RawMessage []byte     `protobuf:"bytes,2,opt,name=raw_message,json=rawMessage,proto3" json:"raw_message,omitempty"`
	// contains filtered or unexported fields
}

type StreamOpen struct {
	NodeId   string            `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Metadata map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Stream_Ack struct {
	Ack *StreamAck `protobuf:"bytes,8,opt,name=ack,proto3,oneof"`
}

type Stream_Close struct {
	Close *StreamClose `protobuf:"bytes,9,opt,name=close,proto3,oneof"`
}

type Stream_Message struct {
	Message *StreamMessage `protobuf:"bytes,7,opt,name=message,proto3,oneof"`
}

type Stream_Open struct {
	Open *StreamOpen `protobuf:"bytes,6,opt,name=open,proto3,oneof"`
}