internal

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 24, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_internal_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ClaimRequest 

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"`
	// contains filtered or unexported fields
}

func (*ClaimRequest) Descriptor deprecated 

func (*ClaimRequest) Descriptor() ([]byte, []int)

Deprecated: Use ClaimRequest.ProtoReflect.Descriptor instead.

func (*ClaimRequest) GetAffinity 

func (x *ClaimRequest) GetAffinity() float32

func (*ClaimRequest) GetRequestId 

func (x *ClaimRequest) GetRequestId() string

func (*ClaimRequest) GetServerId 

func (x *ClaimRequest) GetServerId() string

func (*ClaimRequest) ProtoMessage 

func (*ClaimRequest) ProtoMessage()

func (*ClaimRequest) ProtoReflect 

func (x *ClaimRequest) ProtoReflect() protoreflect.Message

func (*ClaimRequest) Reset 

func (x *ClaimRequest) Reset()

func (*ClaimRequest) String 

func (x *ClaimRequest) String() string

type ClaimResponse 

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
}

func (*ClaimResponse) Descriptor deprecated 

func (*ClaimResponse) Descriptor() ([]byte, []int)

Deprecated: Use ClaimResponse.ProtoReflect.Descriptor instead.

func (*ClaimResponse) GetRequestId 

func (x *ClaimResponse) GetRequestId() string

func (*ClaimResponse) GetServerId 

func (x *ClaimResponse) GetServerId() string

func (*ClaimResponse) ProtoMessage 

func (*ClaimResponse) ProtoMessage()

func (*ClaimResponse) ProtoReflect 

func (x *ClaimResponse) ProtoReflect() protoreflect.Message

func (*ClaimResponse) Reset 

func (x *ClaimResponse) Reset()

func (*ClaimResponse) String 

func (x *ClaimResponse) String() string

type Request 

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 `` /* 157-byte string literal not displayed */
	RawRequest []byte            `protobuf:"bytes,8,opt,name=raw_request,json=rawRequest,proto3" json:"raw_request,omitempty"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated 

func (*Request) Descriptor() ([]byte, []int)

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetClientId 

func (x *Request) GetClientId() string

func (*Request) GetExpiry 

func (x *Request) GetExpiry() int64

func (*Request) GetMetadata added in v0.2.8 

func (x *Request) GetMetadata() map[string]string

func (*Request) GetMulti 

func (x *Request) GetMulti() bool

func (*Request) GetRawRequest added in v0.2.9 

func (x *Request) GetRawRequest() []byte

func (*Request) GetRequest 

func (x *Request) GetRequest() *anypb.Any

func (*Request) GetRequestId 

func (x *Request) GetRequestId() string

func (*Request) GetSentAt 

func (x *Request) GetSentAt() int64

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

func (x *Request) ProtoReflect() protoreflect.Message

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

type Response 

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"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

func (*Response) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetCode added in v0.2.3 

func (x *Response) GetCode() string

func (*Response) GetError 

func (x *Response) GetError() string

func (*Response) GetRawResponse added in v0.2.9 

func (x *Response) GetRawResponse() []byte

func (*Response) GetRequestId 

func (x *Response) GetRequestId() string

func (*Response) GetResponse 

func (x *Response) GetResponse() *anypb.Any

func (*Response) GetSentAt 

func (x *Response) GetSentAt() int64

func (*Response) GetServerId 

func (x *Response) GetServerId() string

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type Stream added in v0.2.5 

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 assignable to Body:
	//
	//	*Stream_Open
	//	*Stream_Message
	//	*Stream_Ack
	//	*Stream_Close
	Body isStream_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

func (*Stream) Descriptor deprecated added in v0.2.5 

func (*Stream) Descriptor() ([]byte, []int)

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetAck added in v0.2.5 

func (x *Stream) GetAck() *StreamAck

func (*Stream) GetBody added in v0.2.5 

func (m *Stream) GetBody() isStream_Body

func (*Stream) GetClose added in v0.2.5 

func (x *Stream) GetClose() *StreamClose

func (*Stream) GetExpiry added in v0.2.5 

func (x *Stream) GetExpiry() int64

func (*Stream) GetMessage added in v0.2.5 

func (x *Stream) GetMessage() *StreamMessage

func (*Stream) GetOpen added in v0.2.5 

func (x *Stream) GetOpen() *StreamOpen

func (*Stream) GetRequestId added in v0.2.5 

func (x *Stream) GetRequestId() string

func (*Stream) GetSentAt added in v0.2.5 

func (x *Stream) GetSentAt() int64

func (*Stream) GetStreamId added in v0.2.5 

func (x *Stream) GetStreamId() string

func (*Stream) ProtoMessage added in v0.2.5 

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect added in v0.2.5 

func (x *Stream) ProtoReflect() protoreflect.Message

func (*Stream) Reset added in v0.2.5 

func (x *Stream) Reset()

func (*Stream) String added in v0.2.5 

func (x *Stream) String() string

type StreamAck added in v0.2.5 

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

func (*StreamAck) Descriptor deprecated added in v0.2.5 

func (*StreamAck) Descriptor() ([]byte, []int)

Deprecated: Use StreamAck.ProtoReflect.Descriptor instead.

func (*StreamAck) ProtoMessage added in v0.2.5 

func (*StreamAck) ProtoMessage()

func (*StreamAck) ProtoReflect added in v0.2.5 

func (x *StreamAck) ProtoReflect() protoreflect.Message

func (*StreamAck) Reset added in v0.2.5 

func (x *StreamAck) Reset()

func (*StreamAck) String added in v0.2.5 

func (x *StreamAck) String() string

type StreamClose added in v0.2.5 

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
}

func (*StreamClose) Descriptor deprecated added in v0.2.5 

func (*StreamClose) Descriptor() ([]byte, []int)

Deprecated: Use StreamClose.ProtoReflect.Descriptor instead.

func (*StreamClose) GetCode added in v0.2.5 

func (x *StreamClose) GetCode() string

func (*StreamClose) GetError added in v0.2.5 

func (x *StreamClose) GetError() string

func (*StreamClose) ProtoMessage added in v0.2.5 

func (*StreamClose) ProtoMessage()

func (*StreamClose) ProtoReflect added in v0.2.5 

func (x *StreamClose) ProtoReflect() protoreflect.Message

func (*StreamClose) Reset added in v0.2.5 

func (x *StreamClose) Reset()

func (*StreamClose) String added in v0.2.5 

func (x *StreamClose) String() string

type StreamMessage added in v0.2.5 

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
}

func (*StreamMessage) Descriptor deprecated added in v0.2.5 

func (*StreamMessage) Descriptor() ([]byte, []int)

Deprecated: Use StreamMessage.ProtoReflect.Descriptor instead.

func (*StreamMessage) GetMessage added in v0.2.5 

func (x *StreamMessage) GetMessage() *anypb.Any

func (*StreamMessage) GetRawMessage added in v0.2.9 

func (x *StreamMessage) GetRawMessage() []byte

func (*StreamMessage) ProtoMessage added in v0.2.5 

func (*StreamMessage) ProtoMessage()

func (*StreamMessage) ProtoReflect added in v0.2.5 

func (x *StreamMessage) ProtoReflect() protoreflect.Message

func (*StreamMessage) Reset added in v0.2.5 

func (x *StreamMessage) Reset()

func (*StreamMessage) String added in v0.2.5 

func (x *StreamMessage) String() string

type StreamOpen added in v0.2.5 

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

func (*StreamOpen) Descriptor deprecated added in v0.2.5 

func (*StreamOpen) Descriptor() ([]byte, []int)

Deprecated: Use StreamOpen.ProtoReflect.Descriptor instead.

func (*StreamOpen) GetMetadata added in v0.2.8 

func (x *StreamOpen) GetMetadata() map[string]string

func (*StreamOpen) GetNodeId added in v0.2.5 

func (x *StreamOpen) GetNodeId() string

func (*StreamOpen) ProtoMessage added in v0.2.5 

func (*StreamOpen) ProtoMessage()

func (*StreamOpen) ProtoReflect added in v0.2.5 

func (x *StreamOpen) ProtoReflect() protoreflect.Message

func (*StreamOpen) Reset added in v0.2.5 

func (x *StreamOpen) Reset()

func (*StreamOpen) String added in v0.2.5 

func (x *StreamOpen) String() string

type Stream_Ack added in v0.2.5 

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

type Stream_Close added in v0.2.5 

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

type Stream_Message added in v0.2.5 

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

type Stream_Open added in v0.2.5 

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

Source Files

View all Source files

Directories

Path Synopsis
test
empty_service
google_protobuf_imports
importable
importer
importer_local
importmapping
importmapping/x
importmapping/y
multiple
my_service
no_package_name
no_package_name_importer
service_method_same_name
snake_case_names

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.