messages

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

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

 Go to latest Published: May 18, 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_SUB",
		7:  "MSG_TYPE_SUB_RSP",
		8:  "MSG_TYPE_SUB_TOPIC_RSP",
		9:  "MSG_TYPE_UNSUB",
		10: "MSG_TYPE_UNSUB_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_SUB":           6,
		"MSG_TYPE_SUB_RSP":       7,
		"MSG_TYPE_SUB_TOPIC_RSP": 8,
		"MSG_TYPE_UNSUB":         9,
		"MSG_TYPE_UNSUB_RSP":     10,
	}
)

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: "Recv",
			Handler:    _Sidecar_Recv_Handler,
		},
		{
			MethodName: "Unsub",
			Handler:    _Sidecar_Unsub_Handler,
		},
		{
			MethodName: "Pub",
			Handler:    _Sidecar_Pub_Handler,
		},
		{
			MethodName: "Log",
			Handler:    _Sidecar_Log_Handler,
		},
		{
			MethodName: "Experiment",
			Handler:    _Sidecar_Experiment_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 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_SUB           MsgType = 6
	MsgType_MSG_TYPE_SUB_RSP       MsgType = 7
	MsgType_MSG_TYPE_SUB_TOPIC_RSP MsgType = 8
	MsgType_MSG_TYPE_UNSUB         MsgType = 9
	MsgType_MSG_TYPE_UNSUB_RSP     MsgType = 10
)

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 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 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)
	Recv(ctx context.Context, in *Receive, opts ...grpc.CallOption) (*SubTopicResponse, error)
	Unsub(ctx context.Context, in *UnsubMsg, opts ...grpc.CallOption) (*UnsubMsgResponse, error)
	Pub(ctx context.Context, in *PubMsg, opts ...grpc.CallOption) (*PubMsgResponse, error)
	Log(ctx context.Context, in *LogMsg, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Experiment(ctx context.Context, in *Doc, 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)
	Recv(context.Context, *Receive) (*SubTopicResponse, error)
	Unsub(context.Context, *UnsubMsg) (*UnsubMsgResponse, error)
	Pub(context.Context, *PubMsg) (*PubMsgResponse, error)
	Log(context.Context, *LogMsg) (*emptypb.Empty, error)
	Experiment(context.Context, *Doc) (*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 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) Experiment 

func (UnimplementedSidecarServer) Experiment(context.Context, *Doc) (*emptypb.Empty, error)

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) Recv 

func (UnimplementedSidecarServer) Recv(context.Context, *Receive) (*SubTopicResponse, 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) Unsub 

func (UnimplementedSidecarServer) Unsub(context.Context, *UnsubMsg) (*UnsubMsgResponse, 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 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.