messages

package
v0.0.0-beta.9-lw Latest Latest
Warning

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

 Go to latest Published: May 20, 2022 License: MIT Imports: 10 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	MsgType_name = map[int32]string{
		0:  "MSG_TYPE_REG",
		1:  "MSG_TYPE_REG_RSP",
		2:  "MSG_TYPE_LOG",
		3:  "MSG_TYPE_LOG_RSP",
		4:  "MSG_TYPE_PUB",
		5:  "MSG_TYPE_PUB_RSP",
		6:  "MSG_TYPE_PUB_JS",
		7:  "MSG_TYPE_PUB_JS_RSP",
		8:  "MSG_TYPE_SUB",
		9:  "MSG_TYPE_SUB_RSP",
		10: "MSG_TYPE_SUB_JS",
		11: "MSG_TYPE_SUB_JS_RSP",
		12: "MSG_TYPE_SUB_TOPIC_RSP",
		13: "MSG_TYPE_SUB_JS_TOPIC_RSP",
		14: "MSG_TYPE_UNSUB",
		15: "MSG_TYPE_UNSUB_RSP",
		16: "MSG_TYPE_UNSUB_JS",
		17: "MSG_TYPE_UNSUB_JS_RSP",
	}
	MsgType_value = map[string]int32{
		"MSG_TYPE_REG":              0,
		"MSG_TYPE_REG_RSP":          1,
		"MSG_TYPE_LOG":              2,
		"MSG_TYPE_LOG_RSP":          3,
		"MSG_TYPE_PUB":              4,
		"MSG_TYPE_PUB_RSP":          5,
		"MSG_TYPE_PUB_JS":           6,
		"MSG_TYPE_PUB_JS_RSP":       7,
		"MSG_TYPE_SUB":              8,
		"MSG_TYPE_SUB_RSP":          9,
		"MSG_TYPE_SUB_JS":           10,
		"MSG_TYPE_SUB_JS_RSP":       11,
		"MSG_TYPE_SUB_TOPIC_RSP":    12,
		"MSG_TYPE_SUB_JS_TOPIC_RSP": 13,
		"MSG_TYPE_UNSUB":            14,
		"MSG_TYPE_UNSUB_RSP":        15,
		"MSG_TYPE_UNSUB_JS":         16,
		"MSG_TYPE_UNSUB_JS_RSP":     17,
	}
)

Enum value maps for MsgType.

View Source 
var (
	Status_name = map[int32]string{
		0: "OK",
		1: "ERR_SENDING_MSG",
		2: "ERR_RECEIVING_MSG",
		3: "ERR_SUBSCRIBING",
		4: "ERR_PUBLISHING",
		5: "ERR_LOGGING",
	}
	Status_value = map[string]int32{
		"OK":                0,
		"ERR_SENDING_MSG":   1,
		"ERR_RECEIVING_MSG": 2,
		"ERR_SUBSCRIBING":   3,
		"ERR_PUBLISHING":    4,
		"ERR_LOGGING":       5,
	}
)

Enum value maps for Status.

View Source 
var File_protos_v1_messages_sidecar_proto protoreflect.FileDescriptor
View Source 
var Sidecar_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "messages.Sidecar",
	HandlerType: (*SidecarServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _Sidecar_Register_Handler,
		},
		{
			MethodName: "Sub",
			Handler:    _Sidecar_Sub_Handler,
		},
		{
			MethodName: "SubJS",
			Handler:    _Sidecar_SubJS_Handler,
		},
		{
			MethodName: "Recv",
			Handler:    _Sidecar_Recv_Handler,
		},
		{
			MethodName: "RecvJS",
			Handler:    _Sidecar_RecvJS_Handler,
		},
		{
			MethodName: "Unsub",
			Handler:    _Sidecar_Unsub_Handler,
		},
		{
			MethodName: "UnsubJS",
			Handler:    _Sidecar_UnsubJS_Handler,
		},
		{
			MethodName: "Pub",
			Handler:    _Sidecar_Pub_Handler,
		},
		{
			MethodName: "PubJS",
			Handler:    _Sidecar_PubJS_Handler,
		},
		{
			MethodName: "Log",
			Handler:    _Sidecar_Log_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/v1/messages/sidecar.proto",
}

Sidecar_ServiceDesc is the grpc.ServiceDesc for Sidecar service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterSidecarServer 

func RegisterSidecarServer(s grpc.ServiceRegistrar, srv SidecarServer)

Types

type Doc 

type Doc struct {
	DocId      uint64   `protobuf:"varint,1,opt,name=docId,proto3" json:"docId,omitempty"`
	WordInts   []uint64 `protobuf:"varint,2,rep,packed,name=wordInts,proto3" json:"wordInts,omitempty"`
	InputDocId string   `protobuf:"bytes,3,opt,name=inputDocId,proto3" json:"inputDocId,omitempty"`
	UserId     string   `protobuf:"bytes,4,opt,name=userId,proto3" json:"userId,omitempty"`
	BusinessId string   `protobuf:"bytes,5,opt,name=businessId,proto3" json:"businessId,omitempty"`
	Stars      float32  `protobuf:"fixed32,6,opt,name=stars,proto3" json:"stars,omitempty"`
	Useful     uint32   `protobuf:"varint,7,opt,name=useful,proto3" json:"useful,omitempty"`
	Funny      uint32   `protobuf:"varint,8,opt,name=funny,proto3" json:"funny,omitempty"`
	Cool       uint32   `protobuf:"varint,9,opt,name=cool,proto3" json:"cool,omitempty"`
	Text       string   `protobuf:"bytes,10,opt,name=text,proto3" json:"text,omitempty"`
	Date       string   `protobuf:"bytes,11,opt,name=date,proto3" json:"date,omitempty"`
	// contains filtered or unexported fields
}

func (*Doc) Descriptor deprecated 

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

Deprecated: Use Doc.ProtoReflect.Descriptor instead.

func (*Doc) GetBusinessId 

func (x *Doc) GetBusinessId() string

func (*Doc) GetCool 

func (x *Doc) GetCool() uint32

func (*Doc) GetDate 

func (x *Doc) GetDate() string

func (*Doc) GetDocId 

func (x *Doc) GetDocId() uint64

func (*Doc) GetFunny 

func (x *Doc) GetFunny() uint32

func (*Doc) GetInputDocId 

func (x *Doc) GetInputDocId() string

func (*Doc) GetStars 

func (x *Doc) GetStars() float32

func (*Doc) GetText 

func (x *Doc) GetText() string

func (*Doc) GetUseful 

func (x *Doc) GetUseful() uint32

func (*Doc) GetUserId 

func (x *Doc) GetUserId() string

func (*Doc) GetWordInts 

func (x *Doc) GetWordInts() []uint64

func (*Doc) ProtoMessage 

func (*Doc) ProtoMessage()

func (*Doc) ProtoReflect 

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

func (*Doc) Reset 

func (x *Doc) Reset()

func (*Doc) String 

func (x *Doc) String() string

type Documents 

type Documents struct {
	Docs []*Doc `protobuf:"bytes,1,rep,name=docs,proto3" json:"docs,omitempty"`
	// contains filtered or unexported fields
}

func (*Documents) Descriptor deprecated 

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

Deprecated: Use Documents.ProtoReflect.Descriptor instead.

func (*Documents) GetDocs 

func (x *Documents) GetDocs() []*Doc

func (*Documents) ProtoMessage 

func (*Documents) ProtoMessage()

func (*Documents) ProtoReflect 

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

func (*Documents) Reset 

func (x *Documents) Reset()

func (*Documents) String 

func (x *Documents) String() string
type Header struct {
	MsgType     MsgType `protobuf:"varint,1,opt,name=msgType,proto3,enum=messages.MsgType" json:"msgType,omitempty"`
	SrcServType string  `protobuf:"bytes,2,opt,name=srcServType,proto3" json:"srcServType,omitempty"`
	DstServType string  `protobuf:"bytes,3,opt,name=dstServType,proto3" json:"dstServType,omitempty"`
	ServId      []byte  `protobuf:"bytes,4,opt,name=servId,proto3" json:"servId,omitempty"`
	MsgId       uint64  `protobuf:"varint,5,opt,name=msgId,proto3" json:"msgId,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetDstServType 

func (x *Header) GetDstServType() string

func (*Header) GetMsgId 

func (x *Header) GetMsgId() uint64

func (*Header) GetMsgType 

func (x *Header) GetMsgType() MsgType

func (*Header) GetServId 

func (x *Header) GetServId() []byte

func (*Header) GetSrcServType 

func (x *Header) GetSrcServType() string

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

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

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type LogMsg 

type LogMsg struct {
	Header *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Msg    string  `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMsg) Descriptor deprecated 

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

Deprecated: Use LogMsg.ProtoReflect.Descriptor instead.

func (*LogMsg) GetHeader 

func (x *LogMsg) GetHeader() *Header

func (*LogMsg) GetMsg 

func (x *LogMsg) GetMsg() string

func (*LogMsg) ProtoMessage 

func (*LogMsg) ProtoMessage()

func (*LogMsg) ProtoReflect 

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

func (*LogMsg) Reset 

func (x *LogMsg) Reset()

func (*LogMsg) String 

func (x *LogMsg) String() string

type LogMsgResponse 

type LogMsgResponse struct {
	Header    *Header         `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	RspHeader *ResponseHeader `protobuf:"bytes,2,opt,name=rspHeader,proto3" json:"rspHeader,omitempty"`
	Msg       string          `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMsgResponse) Descriptor deprecated 

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

Deprecated: Use LogMsgResponse.ProtoReflect.Descriptor instead.

func (*LogMsgResponse) GetHeader 

func (x *LogMsgResponse) GetHeader() *Header

func (*LogMsgResponse) GetMsg 

func (x *LogMsgResponse) GetMsg() string

func (*LogMsgResponse) GetRspHeader 

func (x *LogMsgResponse) GetRspHeader() *ResponseHeader

func (*LogMsgResponse) ProtoMessage 

func (*LogMsgResponse) ProtoMessage()

func (*LogMsgResponse) ProtoReflect 

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

func (*LogMsgResponse) Reset 

func (x *LogMsgResponse) Reset()

func (*LogMsgResponse) String 

func (x *LogMsgResponse) String() string

type MsgType 

type MsgType int32
const (
	MsgType_MSG_TYPE_REG              MsgType = 0
	MsgType_MSG_TYPE_REG_RSP          MsgType = 1
	MsgType_MSG_TYPE_LOG              MsgType = 2
	MsgType_MSG_TYPE_LOG_RSP          MsgType = 3
	MsgType_MSG_TYPE_PUB              MsgType = 4
	MsgType_MSG_TYPE_PUB_RSP          MsgType = 5
	MsgType_MSG_TYPE_PUB_JS           MsgType = 6
	MsgType_MSG_TYPE_PUB_JS_RSP       MsgType = 7
	MsgType_MSG_TYPE_SUB              MsgType = 8
	MsgType_MSG_TYPE_SUB_RSP          MsgType = 9
	MsgType_MSG_TYPE_SUB_JS           MsgType = 10
	MsgType_MSG_TYPE_SUB_JS_RSP       MsgType = 11
	MsgType_MSG_TYPE_SUB_TOPIC_RSP    MsgType = 12
	MsgType_MSG_TYPE_SUB_JS_TOPIC_RSP MsgType = 13
	MsgType_MSG_TYPE_UNSUB            MsgType = 14
	MsgType_MSG_TYPE_UNSUB_RSP        MsgType = 15
	MsgType_MSG_TYPE_UNSUB_JS         MsgType = 16
	MsgType_MSG_TYPE_UNSUB_JS_RSP     MsgType = 17
)

func (MsgType) Descriptor 

func (MsgType) Descriptor() protoreflect.EnumDescriptor

func (MsgType) Enum 

func (x MsgType) Enum() *MsgType

func (MsgType) EnumDescriptor deprecated 

func (MsgType) EnumDescriptor() ([]byte, []int)

Deprecated: Use MsgType.Descriptor instead.

func (MsgType) Number 

func (x MsgType) Number() protoreflect.EnumNumber

func (MsgType) String 

func (x MsgType) String() string

func (MsgType) Type 

func (MsgType) Type() protoreflect.EnumType

type PubJSMsg 

type PubJSMsg struct {
	Header    *Header        `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Topic     string         `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	WorkQueue string         `protobuf:"bytes,3,opt,name=workQueue,proto3" json:"workQueue,omitempty"`
	Msg       []byte         `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`
	Retry     *RetryBehavior `protobuf:"bytes,5,opt,name=Retry,proto3,oneof" json:"Retry,omitempty"`
	// contains filtered or unexported fields
}

func (*PubJSMsg) Descriptor deprecated 

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

Deprecated: Use PubJSMsg.ProtoReflect.Descriptor instead.

func (*PubJSMsg) GetHeader 

func (x *PubJSMsg) GetHeader() *Header

func (*PubJSMsg) GetMsg 

func (x *PubJSMsg) GetMsg() []byte

func (*PubJSMsg) GetRetry 

func (x *PubJSMsg) GetRetry() *RetryBehavior

func (*PubJSMsg) GetTopic 

func (x *PubJSMsg) GetTopic() string

func (*PubJSMsg) GetWorkQueue 

func (x *PubJSMsg) GetWorkQueue() string

func (*PubJSMsg) ProtoMessage 

func (*PubJSMsg) ProtoMessage()

func (*PubJSMsg) ProtoReflect 

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

func (*PubJSMsg) Reset 

func (x *PubJSMsg) Reset()

func (*PubJSMsg) String 

func (x *PubJSMsg) String() string

type PubJSMsgResponse 

type PubJSMsgResponse struct {
	Header    *Header         `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	RspHeader *ResponseHeader `protobuf:"bytes,2,opt,name=rspHeader,proto3" json:"rspHeader,omitempty"`
	Msg       string          `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	WorkQueue string          `protobuf:"bytes,4,opt,name=workQueue,proto3" json:"workQueue,omitempty"`
	// contains filtered or unexported fields
}

func (*PubJSMsgResponse) Descriptor deprecated 

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

Deprecated: Use PubJSMsgResponse.ProtoReflect.Descriptor instead.

func (*PubJSMsgResponse) GetHeader 

func (x *PubJSMsgResponse) GetHeader() *Header

func (*PubJSMsgResponse) GetMsg 

func (x *PubJSMsgResponse) GetMsg() string

func (*PubJSMsgResponse) GetRspHeader 

func (x *PubJSMsgResponse) GetRspHeader() *ResponseHeader

func (*PubJSMsgResponse) GetWorkQueue 

func (x *PubJSMsgResponse) GetWorkQueue() string

func (*PubJSMsgResponse) ProtoMessage 

func (*PubJSMsgResponse) ProtoMessage()

func (*PubJSMsgResponse) ProtoReflect 

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

func (*PubJSMsgResponse) Reset 

func (x *PubJSMsgResponse) Reset()

func (*PubJSMsgResponse) String 

func (x *PubJSMsgResponse) String() string

type PubMsg 

type PubMsg struct {
	Header *Header        `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Topic  string         `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Msg    []byte         `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	Retry  *RetryBehavior `protobuf:"bytes,4,opt,name=Retry,proto3,oneof" json:"Retry,omitempty"`
	// contains filtered or unexported fields
}

Publish the given bytes on the given topic.

func (*PubMsg) Descriptor deprecated 

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

Deprecated: Use PubMsg.ProtoReflect.Descriptor instead.

func (*PubMsg) GetHeader 

func (x *PubMsg) GetHeader() *Header

func (*PubMsg) GetMsg 

func (x *PubMsg) GetMsg() []byte

func (*PubMsg) GetRetry 

func (x *PubMsg) GetRetry() *RetryBehavior

func (*PubMsg) GetTopic 

func (x *PubMsg) GetTopic() string

func (*PubMsg) ProtoMessage 

func (*PubMsg) ProtoMessage()

func (*PubMsg) ProtoReflect 

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

func (*PubMsg) Reset 

func (x *PubMsg) Reset()

func (*PubMsg) String 

func (x *PubMsg) String() string

type PubMsgResponse 

type PubMsgResponse struct {
	Header    *Header         `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	RspHeader *ResponseHeader `protobuf:"bytes,2,opt,name=rspHeader,proto3" json:"rspHeader,omitempty"`
	Msg       string          `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*PubMsgResponse) Descriptor deprecated 

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

Deprecated: Use PubMsgResponse.ProtoReflect.Descriptor instead.

func (*PubMsgResponse) GetHeader 

func (x *PubMsgResponse) GetHeader() *Header

func (*PubMsgResponse) GetMsg 

func (x *PubMsgResponse) GetMsg() string

func (*PubMsgResponse) GetRspHeader 

func (x *PubMsgResponse) GetRspHeader() *ResponseHeader

func (*PubMsgResponse) ProtoMessage 

func (*PubMsgResponse) ProtoMessage()

func (*PubMsgResponse) ProtoReflect 

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

func (*PubMsgResponse) Reset 

func (x *PubMsgResponse) Reset()

func (*PubMsgResponse) String 

func (x *PubMsgResponse) String() string

type Receive 

type Receive struct {
	Header *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Topic  string  `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*Receive) Descriptor deprecated 

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

Deprecated: Use Receive.ProtoReflect.Descriptor instead.

func (*Receive) GetHeader 

func (x *Receive) GetHeader() *Header

func (*Receive) GetTopic 

func (x *Receive) GetTopic() string

func (*Receive) ProtoMessage 

func (*Receive) ProtoMessage()

func (*Receive) ProtoReflect 

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

func (*Receive) Reset 

func (x *Receive) Reset()

func (*Receive) String 

func (x *Receive) String() string

type ReceiveJS 

type ReceiveJS struct {
	Header    *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Topic     string  `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	WorkQueue string  `protobuf:"bytes,3,opt,name=workQueue,proto3" json:"workQueue,omitempty"`
	// contains filtered or unexported fields
}

func (*ReceiveJS) Descriptor deprecated 

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

Deprecated: Use ReceiveJS.ProtoReflect.Descriptor instead.

func (*ReceiveJS) GetHeader 

func (x *ReceiveJS) GetHeader() *Header

func (*ReceiveJS) GetTopic 

func (x *ReceiveJS) GetTopic() string

func (*ReceiveJS) GetWorkQueue 

func (x *ReceiveJS) GetWorkQueue() string

func (*ReceiveJS) ProtoMessage 

func (*ReceiveJS) ProtoMessage()

func (*ReceiveJS) ProtoReflect 

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

func (*ReceiveJS) Reset 

func (x *ReceiveJS) Reset()

func (*ReceiveJS) String 

func (x *ReceiveJS) String() string

type RegistrationMsg 

type RegistrationMsg struct {
	Header      *Header             `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	ServiceName string              `protobuf:"bytes,2,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	RegParams   *RegistrationParams `protobuf:"bytes,3,opt,name=regParams,proto3" json:"regParams,omitempty"`
	// contains filtered or unexported fields
}

func (*RegistrationMsg) Descriptor deprecated 

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

Deprecated: Use RegistrationMsg.ProtoReflect.Descriptor instead.

func (*RegistrationMsg) GetHeader 

func (x *RegistrationMsg) GetHeader() *Header

func (*RegistrationMsg) GetRegParams 

func (x *RegistrationMsg) GetRegParams() *RegistrationParams

func (*RegistrationMsg) GetServiceName 

func (x *RegistrationMsg) GetServiceName() string

func (*RegistrationMsg) ProtoMessage 

func (*RegistrationMsg) ProtoMessage()

func (*RegistrationMsg) ProtoReflect 

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

func (*RegistrationMsg) Reset 

func (x *RegistrationMsg) Reset()

func (*RegistrationMsg) String 

func (x *RegistrationMsg) String() string

type RegistrationMsgResponse 

type RegistrationMsgResponse struct {
	Header         *Header         `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	RspHeader      *ResponseHeader `protobuf:"bytes,2,opt,name=rspHeader,proto3" json:"rspHeader,omitempty"`
	Msg            string          `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	AssignedServId []byte          `protobuf:"bytes,4,opt,name=assignedServId,proto3" json:"assignedServId,omitempty"`
	// contains filtered or unexported fields
}

func (*RegistrationMsgResponse) Descriptor deprecated 

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

Deprecated: Use RegistrationMsgResponse.ProtoReflect.Descriptor instead.

func (*RegistrationMsgResponse) GetAssignedServId 

func (x *RegistrationMsgResponse) GetAssignedServId() []byte

func (*RegistrationMsgResponse) GetHeader 

func (x *RegistrationMsgResponse) GetHeader() *Header

func (*RegistrationMsgResponse) GetMsg 

func (x *RegistrationMsgResponse) GetMsg() string

func (*RegistrationMsgResponse) GetRspHeader 

func (x *RegistrationMsgResponse) GetRspHeader() *ResponseHeader

func (*RegistrationMsgResponse) ProtoMessage 

func (*RegistrationMsgResponse) ProtoMessage()

func (*RegistrationMsgResponse) ProtoReflect 

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

func (*RegistrationMsgResponse) Reset 

func (x *RegistrationMsgResponse) Reset()

func (*RegistrationMsgResponse) String 

func (x *RegistrationMsgResponse) String() string

type RegistrationParams 

type RegistrationParams struct {
	CircuitFailureThreshold *uint32              `protobuf:"varint,3,opt,name=circuitFailureThreshold,proto3,oneof" json:"circuitFailureThreshold,omitempty"`
	DebounceDelay           *durationpb.Duration `protobuf:"bytes,4,opt,name=debounceDelay,proto3,oneof" json:"debounceDelay,omitempty"`
	Retry                   *RetryBehavior       `protobuf:"bytes,5,opt,name=Retry,proto3,oneof" json:"Retry,omitempty"`
	// contains filtered or unexported fields
}

func (*RegistrationParams) Descriptor deprecated 

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

Deprecated: Use RegistrationParams.ProtoReflect.Descriptor instead.

func (*RegistrationParams) GetCircuitFailureThreshold 

func (x *RegistrationParams) GetCircuitFailureThreshold() uint32

func (*RegistrationParams) GetDebounceDelay 

func (x *RegistrationParams) GetDebounceDelay() *durationpb.Duration

func (*RegistrationParams) GetRetry 

func (x *RegistrationParams) GetRetry() *RetryBehavior

func (*RegistrationParams) ProtoMessage 

func (*RegistrationParams) ProtoMessage()

func (*RegistrationParams) ProtoReflect 

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

func (*RegistrationParams) Reset 

func (x *RegistrationParams) Reset()

func (*RegistrationParams) String 

func (x *RegistrationParams) String() string

type ResponseHeader 

type ResponseHeader struct {
	Status uint32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ResponseHeader) Descriptor deprecated 

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

Deprecated: Use ResponseHeader.ProtoReflect.Descriptor instead.

func (*ResponseHeader) GetStatus 

func (x *ResponseHeader) GetStatus() uint32

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) ProtoReflect 

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

func (*ResponseHeader) Reset 

func (x *ResponseHeader) Reset()

func (*ResponseHeader) String 

func (x *ResponseHeader) String() string

type RetryBehavior 

type RetryBehavior struct {
	RetryNum   *uint32              `protobuf:"varint,1,opt,name=retryNum,proto3,oneof" json:"retryNum,omitempty"`
	RetryDelay *durationpb.Duration `protobuf:"bytes,2,opt,name=retryDelay,proto3,oneof" json:"retryDelay,omitempty"`
	// contains filtered or unexported fields
}

func (*RetryBehavior) Descriptor deprecated 

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

Deprecated: Use RetryBehavior.ProtoReflect.Descriptor instead.

func (*RetryBehavior) GetRetryDelay 

func (x *RetryBehavior) GetRetryDelay() *durationpb.Duration

func (*RetryBehavior) GetRetryNum 

func (x *RetryBehavior) GetRetryNum() uint32

func (*RetryBehavior) ProtoMessage 

func (*RetryBehavior) ProtoMessage()

func (*RetryBehavior) ProtoReflect 

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

func (*RetryBehavior) Reset 

func (x *RetryBehavior) Reset()

func (*RetryBehavior) String 

func (x *RetryBehavior) String() string

type SidecarClient 

type SidecarClient interface {
	Register(ctx context.Context, in *RegistrationMsg, opts ...grpc.CallOption) (*RegistrationMsgResponse, error)
	Sub(ctx context.Context, in *SubMsg, opts ...grpc.CallOption) (*SubMsgResponse, error)
	SubJS(ctx context.Context, in *SubJSMsg, opts ...grpc.CallOption) (*SubJSMsgResponse, error)
	Recv(ctx context.Context, in *Receive, opts ...grpc.CallOption) (*SubTopicResponse, error)
	RecvJS(ctx context.Context, in *ReceiveJS, opts ...grpc.CallOption) (*SubJSTopicResponse, error)
	Unsub(ctx context.Context, in *UnsubMsg, opts ...grpc.CallOption) (*UnsubMsgResponse, error)
	UnsubJS(ctx context.Context, in *UnsubJSMsg, opts ...grpc.CallOption) (*UnsubJSMsgResponse, error)
	Pub(ctx context.Context, in *PubMsg, opts ...grpc.CallOption) (*PubMsgResponse, error)
	PubJS(ctx context.Context, in *PubJSMsg, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Log(ctx context.Context, in *LogMsg, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

SidecarClient is the client API for Sidecar service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSidecarClient 

func NewSidecarClient(cc grpc.ClientConnInterface) SidecarClient

type SidecarServer 

type SidecarServer interface {
	Register(context.Context, *RegistrationMsg) (*RegistrationMsgResponse, error)
	Sub(context.Context, *SubMsg) (*SubMsgResponse, error)
	SubJS(context.Context, *SubJSMsg) (*SubJSMsgResponse, error)
	Recv(context.Context, *Receive) (*SubTopicResponse, error)
	RecvJS(context.Context, *ReceiveJS) (*SubJSTopicResponse, error)
	Unsub(context.Context, *UnsubMsg) (*UnsubMsgResponse, error)
	UnsubJS(context.Context, *UnsubJSMsg) (*UnsubJSMsgResponse, error)
	Pub(context.Context, *PubMsg) (*PubMsgResponse, error)
	PubJS(context.Context, *PubJSMsg) (*emptypb.Empty, error)
	Log(context.Context, *LogMsg) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

SidecarServer is the server API for Sidecar service. All implementations must embed UnimplementedSidecarServer for forward compatibility

type Status 

type Status int32
const (
	Status_OK                Status = 0
	Status_ERR_SENDING_MSG   Status = 1
	Status_ERR_RECEIVING_MSG Status = 2
	Status_ERR_SUBSCRIBING   Status = 3
	Status_ERR_PUBLISHING    Status = 4
	Status_ERR_LOGGING       Status = 5
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

func (Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Status.Descriptor instead.

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

type SubJSMsg 

type SubJSMsg struct {
	Header    *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Topic     string  `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	WorkQueue string  `protobuf:"bytes,3,opt,name=workQueue,proto3" json:"workQueue,omitempty"`
	ChanSize  uint32  `protobuf:"varint,4,opt,name=chanSize,proto3" json:"chanSize,omitempty"`
	// contains filtered or unexported fields
}

func (*SubJSMsg) Descriptor deprecated 

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

Deprecated: Use SubJSMsg.ProtoReflect.Descriptor instead.

func (*SubJSMsg) GetChanSize 

func (x *SubJSMsg) GetChanSize() uint32

func (*SubJSMsg) GetHeader 

func (x *SubJSMsg) GetHeader() *Header

func (*SubJSMsg) GetTopic 

func (x *SubJSMsg) GetTopic() string

func (*SubJSMsg) GetWorkQueue 

func (x *SubJSMsg) GetWorkQueue() string

func (*SubJSMsg) ProtoMessage 

func (*SubJSMsg) ProtoMessage()

func (*SubJSMsg) ProtoReflect 

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

func (*SubJSMsg) Reset 

func (x *SubJSMsg) Reset()

func (*SubJSMsg) String 

func (x *SubJSMsg) String() string

type SubJSMsgResponse 

type SubJSMsgResponse struct {
	Header    *Header         `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	RspHeader *ResponseHeader `protobuf:"bytes,2,opt,name=rspHeader,proto3" json:"rspHeader,omitempty"`
	Msg       string          `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*SubJSMsgResponse) Descriptor deprecated 

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

Deprecated: Use SubJSMsgResponse.ProtoReflect.Descriptor instead.

func (*SubJSMsgResponse) GetHeader 

func (x *SubJSMsgResponse) GetHeader() *Header

func (*SubJSMsgResponse) GetMsg 

func (x *SubJSMsgResponse) GetMsg() string

func (*SubJSMsgResponse) GetRspHeader 

func (x *SubJSMsgResponse) GetRspHeader() *ResponseHeader

func (*SubJSMsgResponse) ProtoMessage 

func (*SubJSMsgResponse) ProtoMessage()

func (*SubJSMsgResponse) ProtoReflect 

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

func (*SubJSMsgResponse) Reset 

func (x *SubJSMsgResponse) Reset()

func (*SubJSMsgResponse) String 

func (x *SubJSMsgResponse) String() string

type SubJSTopicResponse 

type SubJSTopicResponse struct {
	Header    *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Topic     string  `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	WorkQueue string  `protobuf:"bytes,3,opt,name=workQueue,proto3" json:"workQueue,omitempty"`
	Msg       []byte  `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*SubJSTopicResponse) Descriptor deprecated 

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

Deprecated: Use SubJSTopicResponse.ProtoReflect.Descriptor instead.

func (*SubJSTopicResponse) GetHeader 

func (x *SubJSTopicResponse) GetHeader() *Header

func (*SubJSTopicResponse) GetMsg 

func (x *SubJSTopicResponse) GetMsg() []byte

func (*SubJSTopicResponse) GetTopic 

func (x *SubJSTopicResponse) GetTopic() string

func (*SubJSTopicResponse) GetWorkQueue 

func (x *SubJSTopicResponse) GetWorkQueue() string

func (*SubJSTopicResponse) ProtoMessage 

func (*SubJSTopicResponse) ProtoMessage()

func (*SubJSTopicResponse) ProtoReflect 

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

func (*SubJSTopicResponse) Reset 

func (x *SubJSTopicResponse) Reset()

func (*SubJSTopicResponse) String 

func (x *SubJSTopicResponse) String() string

type SubMsg 

type SubMsg struct {
	Header   *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Topic    string  `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	ChanSize uint32  `protobuf:"varint,3,opt,name=chanSize,proto3" json:"chanSize,omitempty"`
	// contains filtered or unexported fields
}

func (*SubMsg) Descriptor deprecated 

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

Deprecated: Use SubMsg.ProtoReflect.Descriptor instead.

func (*SubMsg) GetChanSize 

func (x *SubMsg) GetChanSize() uint32

func (*SubMsg) GetHeader 

func (x *SubMsg) GetHeader() *Header

func (*SubMsg) GetTopic 

func (x *SubMsg) GetTopic() string

func (*SubMsg) ProtoMessage 

func (*SubMsg) ProtoMessage()

func (*SubMsg) ProtoReflect 

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

func (*SubMsg) Reset 

func (x *SubMsg) Reset()

func (*SubMsg) String 

func (x *SubMsg) String() string

type SubMsgResponse 

type SubMsgResponse struct {
	Header    *Header         `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	RspHeader *ResponseHeader `protobuf:"bytes,2,opt,name=rspHeader,proto3" json:"rspHeader,omitempty"`
	Msg       string          `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*SubMsgResponse) Descriptor deprecated 

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

Deprecated: Use SubMsgResponse.ProtoReflect.Descriptor instead.

func (*SubMsgResponse) GetHeader 

func (x *SubMsgResponse) GetHeader() *Header

func (*SubMsgResponse) GetMsg 

func (x *SubMsgResponse) GetMsg() string

func (*SubMsgResponse) GetRspHeader 

func (x *SubMsgResponse) GetRspHeader() *ResponseHeader

func (*SubMsgResponse) ProtoMessage 

func (*SubMsgResponse) ProtoMessage()

func (*SubMsgResponse) ProtoReflect 

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

func (*SubMsgResponse) Reset 

func (x *SubMsgResponse) Reset()

func (*SubMsgResponse) String 

func (x *SubMsgResponse) String() string

type SubTopicResponse 

type SubTopicResponse struct {
	Header *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Topic  string  `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Msg    []byte  `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

Change this to SubTopicMsg. This is the message coming from NATS server for the specific topic to which this sidecar has subscribed.

func (*SubTopicResponse) Descriptor deprecated 

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

Deprecated: Use SubTopicResponse.ProtoReflect.Descriptor instead.

func (*SubTopicResponse) GetHeader 

func (x *SubTopicResponse) GetHeader() *Header

func (*SubTopicResponse) GetMsg 

func (x *SubTopicResponse) GetMsg() []byte

func (*SubTopicResponse) GetTopic 

func (x *SubTopicResponse) GetTopic() string

func (*SubTopicResponse) ProtoMessage 

func (*SubTopicResponse) ProtoMessage()

func (*SubTopicResponse) ProtoReflect 

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

func (*SubTopicResponse) Reset 

func (x *SubTopicResponse) Reset()

func (*SubTopicResponse) String 

func (x *SubTopicResponse) String() string

type UnimplementedSidecarServer 

type UnimplementedSidecarServer struct {
}

UnimplementedSidecarServer must be embedded to have forward compatible implementations.

func (UnimplementedSidecarServer) Log 

func (UnimplementedSidecarServer) Log(context.Context, *LogMsg) (*emptypb.Empty, error)

func (UnimplementedSidecarServer) Pub 

func (UnimplementedSidecarServer) Pub(context.Context, *PubMsg) (*PubMsgResponse, error)

func (UnimplementedSidecarServer) PubJS 

func (UnimplementedSidecarServer) PubJS(context.Context, *PubJSMsg) (*emptypb.Empty, error)

func (UnimplementedSidecarServer) Recv 

func (UnimplementedSidecarServer) Recv(context.Context, *Receive) (*SubTopicResponse, error)

func (UnimplementedSidecarServer) RecvJS 

func (UnimplementedSidecarServer) RecvJS(context.Context, *ReceiveJS) (*SubJSTopicResponse, error)

func (UnimplementedSidecarServer) Register 

func (UnimplementedSidecarServer) Register(context.Context, *RegistrationMsg) (*RegistrationMsgResponse, error)

func (UnimplementedSidecarServer) Sub 

func (UnimplementedSidecarServer) Sub(context.Context, *SubMsg) (*SubMsgResponse, error)

func (UnimplementedSidecarServer) SubJS 

func (UnimplementedSidecarServer) SubJS(context.Context, *SubJSMsg) (*SubJSMsgResponse, error)

func (UnimplementedSidecarServer) Unsub 

func (UnimplementedSidecarServer) Unsub(context.Context, *UnsubMsg) (*UnsubMsgResponse, error)

func (UnimplementedSidecarServer) UnsubJS 

func (UnimplementedSidecarServer) UnsubJS(context.Context, *UnsubJSMsg) (*UnsubJSMsgResponse, error)

type UnsafeSidecarServer 

type UnsafeSidecarServer interface {
	// contains filtered or unexported methods
}

UnsafeSidecarServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SidecarServer will result in compilation errors.

type UnsubJSMsg 

type UnsubJSMsg struct {
	Header    *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Topic     string  `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	WorkQueue string  `protobuf:"bytes,3,opt,name=workQueue,proto3" json:"workQueue,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubJSMsg) Descriptor deprecated 

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

Deprecated: Use UnsubJSMsg.ProtoReflect.Descriptor instead.

func (*UnsubJSMsg) GetHeader 

func (x *UnsubJSMsg) GetHeader() *Header

func (*UnsubJSMsg) GetTopic 

func (x *UnsubJSMsg) GetTopic() string

func (*UnsubJSMsg) GetWorkQueue 

func (x *UnsubJSMsg) GetWorkQueue() string

func (*UnsubJSMsg) ProtoMessage 

func (*UnsubJSMsg) ProtoMessage()

func (*UnsubJSMsg) ProtoReflect 

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

func (*UnsubJSMsg) Reset 

func (x *UnsubJSMsg) Reset()

func (*UnsubJSMsg) String 

func (x *UnsubJSMsg) String() string

type UnsubJSMsgResponse 

type UnsubJSMsgResponse struct {
	Header    *Header         `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	RspHeader *ResponseHeader `protobuf:"bytes,2,opt,name=rspHeader,proto3" json:"rspHeader,omitempty"`
	Msg       string          `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubJSMsgResponse) Descriptor deprecated 

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

Deprecated: Use UnsubJSMsgResponse.ProtoReflect.Descriptor instead.

func (*UnsubJSMsgResponse) GetHeader 

func (x *UnsubJSMsgResponse) GetHeader() *Header

func (*UnsubJSMsgResponse) GetMsg 

func (x *UnsubJSMsgResponse) GetMsg() string

func (*UnsubJSMsgResponse) GetRspHeader 

func (x *UnsubJSMsgResponse) GetRspHeader() *ResponseHeader

func (*UnsubJSMsgResponse) ProtoMessage 

func (*UnsubJSMsgResponse) ProtoMessage()

func (*UnsubJSMsgResponse) ProtoReflect 

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

func (*UnsubJSMsgResponse) Reset 

func (x *UnsubJSMsgResponse) Reset()

func (*UnsubJSMsgResponse) String 

func (x *UnsubJSMsgResponse) String() string

type UnsubMsg 

type UnsubMsg struct {
	Header *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Topic  string  `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubMsg) Descriptor deprecated 

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

Deprecated: Use UnsubMsg.ProtoReflect.Descriptor instead.

func (*UnsubMsg) GetHeader 

func (x *UnsubMsg) GetHeader() *Header

func (*UnsubMsg) GetTopic 

func (x *UnsubMsg) GetTopic() string

func (*UnsubMsg) ProtoMessage 

func (*UnsubMsg) ProtoMessage()

func (*UnsubMsg) ProtoReflect 

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

func (*UnsubMsg) Reset 

func (x *UnsubMsg) Reset()

func (*UnsubMsg) String 

func (x *UnsubMsg) String() string

type UnsubMsgResponse 

type UnsubMsgResponse struct {
	Header    *Header         `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	RspHeader *ResponseHeader `protobuf:"bytes,2,opt,name=rspHeader,proto3" json:"rspHeader,omitempty"`
	Msg       string          `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubMsgResponse) Descriptor deprecated 

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

Deprecated: Use UnsubMsgResponse.ProtoReflect.Descriptor instead.

func (*UnsubMsgResponse) GetHeader 

func (x *UnsubMsgResponse) GetHeader() *Header

func (*UnsubMsgResponse) GetMsg 

func (x *UnsubMsgResponse) GetMsg() string

func (*UnsubMsgResponse) GetRspHeader 

func (x *UnsubMsgResponse) GetRspHeader() *ResponseHeader

func (*UnsubMsgResponse) ProtoMessage 

func (*UnsubMsgResponse) ProtoMessage()

func (*UnsubMsgResponse) ProtoReflect 

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

func (*UnsubMsgResponse) Reset 

func (x *UnsubMsgResponse) Reset()

func (*UnsubMsgResponse) String 

func (x *UnsubMsgResponse) String() string

Source Files

View all Source files

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.