pb

package
v1.1.2 Latest Latest
Warning

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

 Go to latest Published: May 3, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthKubemqGo = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowKubemqGo   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Request_RequestType_name = map[int32]string{
	0: "RequestTypeUnknown",
	1: "Command",
	2: "Query",
}
View Source 
var Request_RequestType_value = map[string]int32{
	"RequestTypeUnknown": 0,
	"Command":            1,
	"Query":              2,
}
View Source 
var Subscribe_EventsStoreType_name = map[int32]string{
	0: "EventsStoreTypeUndefined",
	1: "StartNewOnly",
	2: "StartFromFirst",
	3: "StartFromLast",
	4: "StartAtSequence",
	5: "StartAtTime",
	6: "StartAtTimeDelta",
}
View Source 
var Subscribe_EventsStoreType_value = map[string]int32{
	"EventsStoreTypeUndefined": 0,
	"StartNewOnly":             1,
	"StartFromFirst":           2,
	"StartFromLast":            3,
	"StartAtSequence":          4,
	"StartAtTime":              5,
	"StartAtTimeDelta":         6,
}
View Source 
var Subscribe_SubscribeType_name = map[int32]string{
	0: "SubscribeTypeUndefined",
	1: "Events",
	2: "EventsStore",
	3: "Commands",
	4: "Queries",
}
View Source 
var Subscribe_SubscribeType_value = map[string]int32{
	"SubscribeTypeUndefined": 0,
	"Events":                 1,
	"EventsStore":            2,
	"Commands":               3,
	"Queries":                4,
}

Functions

func RegisterKubemqServer 

func RegisterKubemqServer(s *grpc.Server, srv KubemqServer)

Types

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedEmpty 

func NewPopulatedEmpty(r randyKubemqGo, easy bool) *Empty

func (*Empty) Descriptor 

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

func (*Empty) Equal 

func (this *Empty) Equal(that interface{}) bool

func (*Empty) GoString 

func (this *Empty) GoString() string

func (*Empty) Marshal 

func (m *Empty) Marshal() (dAtA []byte, err error)

func (*Empty) MarshalTo 

func (m *Empty) MarshalTo(dAtA []byte) (int, error)

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) Size 

func (m *Empty) Size() (n int)

func (*Empty) String 

func (this *Empty) String() string

func (*Empty) Unmarshal 

func (m *Empty) Unmarshal(dAtA []byte) error

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge 

func (dst *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

func (m *Empty) XXX_Unmarshal(b []byte) error

type Event 

type Event struct {
	EventID              string   `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	ClientID             string   `protobuf:"bytes,2,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	Channel              string   `protobuf:"bytes,3,opt,name=Channel,proto3" json:"Channel,omitempty"`
	Metadata             string   `protobuf:"bytes,4,opt,name=Metadata,proto3" json:"Metadata,omitempty"`
	Body                 []byte   `protobuf:"bytes,5,opt,name=Body,proto3" json:"Body,omitempty"`
	Store                bool     `protobuf:"varint,6,opt,name=Store,proto3" json:"Store,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedEvent 

func NewPopulatedEvent(r randyKubemqGo, easy bool) *Event

func (*Event) Descriptor 

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

func (*Event) Equal 

func (this *Event) Equal(that interface{}) bool

func (*Event) GetBody 

func (m *Event) GetBody() []byte

func (*Event) GetChannel 

func (m *Event) GetChannel() string

func (*Event) GetClientID 

func (m *Event) GetClientID() string

func (*Event) GetEventID 

func (m *Event) GetEventID() string

func (*Event) GetMetadata 

func (m *Event) GetMetadata() string

func (*Event) GetStore 

func (m *Event) GetStore() bool

func (*Event) GoString 

func (this *Event) GoString() string

func (*Event) Marshal 

func (m *Event) Marshal() (dAtA []byte, err error)

func (*Event) MarshalTo 

func (m *Event) MarshalTo(dAtA []byte) (int, error)

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

func (m *Event) Size() (n int)

func (*Event) String 

func (this *Event) String() string

func (*Event) Unmarshal 

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (dst *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type EventReceive 

type EventReceive struct {
	EventID              string   `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Channel              string   `protobuf:"bytes,2,opt,name=Channel,proto3" json:"Channel,omitempty"`
	Metadata             string   `protobuf:"bytes,3,opt,name=Metadata,proto3" json:"Metadata,omitempty"`
	Body                 []byte   `protobuf:"bytes,4,opt,name=Body,proto3" json:"Body,omitempty"`
	Timestamp            int64    `protobuf:"varint,5,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Sequence             uint64   `protobuf:"varint,6,opt,name=Sequence,proto3" json:"Sequence,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedEventReceive 

func NewPopulatedEventReceive(r randyKubemqGo, easy bool) *EventReceive

func (*EventReceive) Descriptor 

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

func (*EventReceive) Equal 

func (this *EventReceive) Equal(that interface{}) bool

func (*EventReceive) GetBody 

func (m *EventReceive) GetBody() []byte

func (*EventReceive) GetChannel 

func (m *EventReceive) GetChannel() string

func (*EventReceive) GetEventID 

func (m *EventReceive) GetEventID() string

func (*EventReceive) GetMetadata 

func (m *EventReceive) GetMetadata() string

func (*EventReceive) GetSequence 

func (m *EventReceive) GetSequence() uint64

func (*EventReceive) GetTimestamp 

func (m *EventReceive) GetTimestamp() int64

func (*EventReceive) GoString 

func (this *EventReceive) GoString() string

func (*EventReceive) Marshal 

func (m *EventReceive) Marshal() (dAtA []byte, err error)

func (*EventReceive) MarshalTo 

func (m *EventReceive) MarshalTo(dAtA []byte) (int, error)

func (*EventReceive) ProtoMessage 

func (*EventReceive) ProtoMessage()

func (*EventReceive) Reset 

func (m *EventReceive) Reset()

func (*EventReceive) Size 

func (m *EventReceive) Size() (n int)

func (*EventReceive) String 

func (this *EventReceive) String() string

func (*EventReceive) Unmarshal 

func (m *EventReceive) Unmarshal(dAtA []byte) error

func (*EventReceive) XXX_DiscardUnknown 

func (m *EventReceive) XXX_DiscardUnknown()

func (*EventReceive) XXX_Marshal 

func (m *EventReceive) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventReceive) XXX_Merge 

func (dst *EventReceive) XXX_Merge(src proto.Message)

func (*EventReceive) XXX_Size 

func (m *EventReceive) XXX_Size() int

func (*EventReceive) XXX_Unmarshal 

func (m *EventReceive) XXX_Unmarshal(b []byte) error

type KubemqClient 

type KubemqClient interface {
	SendEvent(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Result, error)
	SendEventsStream(ctx context.Context, opts ...grpc.CallOption) (Kubemq_SendEventsStreamClient, error)
	SubscribeToEvents(ctx context.Context, in *Subscribe, opts ...grpc.CallOption) (Kubemq_SubscribeToEventsClient, error)
	SubscribeToRequests(ctx context.Context, in *Subscribe, opts ...grpc.CallOption) (Kubemq_SubscribeToRequestsClient, error)
	SendRequest(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	SendResponse(ctx context.Context, in *Response, opts ...grpc.CallOption) (*Empty, error)
}

func NewKubemqClient 

func NewKubemqClient(cc *grpc.ClientConn) KubemqClient

type KubemqServer 

type KubemqServer interface {
	SendEvent(context.Context, *Event) (*Result, error)
	SendEventsStream(Kubemq_SendEventsStreamServer) error
	SubscribeToEvents(*Subscribe, Kubemq_SubscribeToEventsServer) error
	SubscribeToRequests(*Subscribe, Kubemq_SubscribeToRequestsServer) error
	SendRequest(context.Context, *Request) (*Response, error)
	SendResponse(context.Context, *Response) (*Empty, error)
}

type Kubemq_SendEventsStreamClient 

type Kubemq_SendEventsStreamClient interface {
	Send(*Event) error
	Recv() (*Result, error)
	grpc.ClientStream
}

type Kubemq_SendEventsStreamServer 

type Kubemq_SendEventsStreamServer interface {
	Send(*Result) error
	Recv() (*Event, error)
	grpc.ServerStream
}

type Kubemq_SubscribeToEventsClient 

type Kubemq_SubscribeToEventsClient interface {
	Recv() (*EventReceive, error)
	grpc.ClientStream
}

type Kubemq_SubscribeToEventsServer 

type Kubemq_SubscribeToEventsServer interface {
	Send(*EventReceive) error
	grpc.ServerStream
}

type Kubemq_SubscribeToRequestsClient 

type Kubemq_SubscribeToRequestsClient interface {
	Recv() (*Request, error)
	grpc.ClientStream
}

type Kubemq_SubscribeToRequestsServer 

type Kubemq_SubscribeToRequestsServer interface {
	Send(*Request) error
	grpc.ServerStream
}

type Request 

type Request struct {
	RequestID            string              `protobuf:"bytes,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	RequestTypeData      Request_RequestType `protobuf:"varint,2,opt,name=RequestTypeData,proto3,enum=kubemq.Request_RequestType" json:"RequestTypeData,omitempty"`
	ClientID             string              `protobuf:"bytes,3,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	Channel              string              `protobuf:"bytes,4,opt,name=Channel,proto3" json:"Channel,omitempty"`
	Metadata             string              `protobuf:"bytes,5,opt,name=Metadata,proto3" json:"Metadata,omitempty"`
	Body                 []byte              `protobuf:"bytes,6,opt,name=Body,proto3" json:"Body,omitempty"`
	ReplyChannel         string              `protobuf:"bytes,7,opt,name=ReplyChannel,proto3" json:"ReplyChannel,omitempty"`
	Timeout              int32               `protobuf:"varint,8,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	CacheKey             string              `protobuf:"bytes,9,opt,name=CacheKey,proto3" json:"CacheKey,omitempty"`
	CacheTTL             int32               `protobuf:"varint,10,opt,name=CacheTTL,proto3" json:"CacheTTL,omitempty"`
	Span                 []byte              `protobuf:"bytes,11,opt,name=Span,proto3" json:"Span,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func NewPopulatedRequest 

func NewPopulatedRequest(r randyKubemqGo, easy bool) *Request

func (*Request) Descriptor 

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

func (*Request) Equal 

func (this *Request) Equal(that interface{}) bool

func (*Request) GetBody 

func (m *Request) GetBody() []byte

func (*Request) GetCacheKey 

func (m *Request) GetCacheKey() string

func (*Request) GetCacheTTL 

func (m *Request) GetCacheTTL() int32

func (*Request) GetChannel 

func (m *Request) GetChannel() string

func (*Request) GetClientID 

func (m *Request) GetClientID() string

func (*Request) GetMetadata 

func (m *Request) GetMetadata() string

func (*Request) GetReplyChannel 

func (m *Request) GetReplyChannel() string

func (*Request) GetRequestID 

func (m *Request) GetRequestID() string

func (*Request) GetRequestTypeData 

func (m *Request) GetRequestTypeData() Request_RequestType

func (*Request) GetSpan 

func (m *Request) GetSpan() []byte

func (*Request) GetTimeout 

func (m *Request) GetTimeout() int32

func (*Request) GoString 

func (this *Request) GoString() string

func (*Request) Marshal 

func (m *Request) Marshal() (dAtA []byte, err error)

func (*Request) MarshalTo 

func (m *Request) MarshalTo(dAtA []byte) (int, error)

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

func (m *Request) Size() (n int)

func (*Request) String 

func (this *Request) String() string

func (*Request) Unmarshal 

func (m *Request) Unmarshal(dAtA []byte) error

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Request) XXX_Merge 

func (dst *Request) XXX_Merge(src proto.Message)

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

func (m *Request) XXX_Unmarshal(b []byte) error

type Request_RequestType 

type Request_RequestType int32
const (
	RequestTypeUnknown Request_RequestType = 0
	Command            Request_RequestType = 1
	Query              Request_RequestType = 2
)

func (Request_RequestType) EnumDescriptor 

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

func (Request_RequestType) String 

func (x Request_RequestType) String() string

type Response 

type Response struct {
	ClientID             string   `protobuf:"bytes,1,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	RequestID            string   `protobuf:"bytes,2,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	ReplyChannel         string   `protobuf:"bytes,3,opt,name=ReplyChannel,proto3" json:"ReplyChannel,omitempty"`
	Metadata             string   `protobuf:"bytes,4,opt,name=Metadata,proto3" json:"Metadata,omitempty"`
	Body                 []byte   `protobuf:"bytes,5,opt,name=Body,proto3" json:"Body,omitempty"`
	CacheHit             bool     `protobuf:"varint,6,opt,name=CacheHit,proto3" json:"CacheHit,omitempty"`
	Timestamp            int64    `protobuf:"varint,7,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Executed             bool     `protobuf:"varint,8,opt,name=Executed,proto3" json:"Executed,omitempty"`
	Error                string   `protobuf:"bytes,9,opt,name=Error,proto3" json:"Error,omitempty"`
	Span                 []byte   `protobuf:"bytes,10,opt,name=Span,proto3" json:"Span,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedResponse 

func NewPopulatedResponse(r randyKubemqGo, easy bool) *Response

func (*Response) Descriptor 

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

func (*Response) Equal 

func (this *Response) Equal(that interface{}) bool

func (*Response) GetBody 

func (m *Response) GetBody() []byte

func (*Response) GetCacheHit 

func (m *Response) GetCacheHit() bool

func (*Response) GetClientID 

func (m *Response) GetClientID() string

func (*Response) GetError 

func (m *Response) GetError() string

func (*Response) GetExecuted 

func (m *Response) GetExecuted() bool

func (*Response) GetMetadata 

func (m *Response) GetMetadata() string

func (*Response) GetReplyChannel 

func (m *Response) GetReplyChannel() string

func (*Response) GetRequestID 

func (m *Response) GetRequestID() string

func (*Response) GetSpan 

func (m *Response) GetSpan() []byte

func (*Response) GetTimestamp 

func (m *Response) GetTimestamp() int64

func (*Response) GoString 

func (this *Response) GoString() string

func (*Response) Marshal 

func (m *Response) Marshal() (dAtA []byte, err error)

func (*Response) MarshalTo 

func (m *Response) MarshalTo(dAtA []byte) (int, error)

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

func (m *Response) Size() (n int)

func (*Response) String 

func (this *Response) String() string

func (*Response) Unmarshal 

func (m *Response) Unmarshal(dAtA []byte) error

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Response) XXX_Merge 

func (dst *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

func (m *Response) XXX_Unmarshal(b []byte) error

type Result 

type Result struct {
	EventID              string   `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Sent                 bool     `protobuf:"varint,2,opt,name=Sent,proto3" json:"Sent,omitempty"`
	Error                string   `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedResult 

func NewPopulatedResult(r randyKubemqGo, easy bool) *Result

func (*Result) Descriptor 

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

func (*Result) Equal 

func (this *Result) Equal(that interface{}) bool

func (*Result) GetError 

func (m *Result) GetError() string

func (*Result) GetEventID 

func (m *Result) GetEventID() string

func (*Result) GetSent 

func (m *Result) GetSent() bool

func (*Result) GoString 

func (this *Result) GoString() string

func (*Result) Marshal 

func (m *Result) Marshal() (dAtA []byte, err error)

func (*Result) MarshalTo 

func (m *Result) MarshalTo(dAtA []byte) (int, error)

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) Reset 

func (m *Result) Reset()

func (*Result) Size 

func (m *Result) Size() (n int)

func (*Result) String 

func (this *Result) String() string

func (*Result) Unmarshal 

func (m *Result) Unmarshal(dAtA []byte) error

func (*Result) XXX_DiscardUnknown 

func (m *Result) XXX_DiscardUnknown()

func (*Result) XXX_Marshal 

func (m *Result) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Result) XXX_Merge 

func (dst *Result) XXX_Merge(src proto.Message)

func (*Result) XXX_Size 

func (m *Result) XXX_Size() int

func (*Result) XXX_Unmarshal 

func (m *Result) XXX_Unmarshal(b []byte) error

type Subscribe 

type Subscribe struct {
	SubscribeTypeData    Subscribe_SubscribeType   `protobuf:"varint,1,opt,name=SubscribeTypeData,proto3,enum=kubemq.Subscribe_SubscribeType" json:"SubscribeTypeData,omitempty"`
	ClientID             string                    `protobuf:"bytes,2,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	Channel              string                    `protobuf:"bytes,3,opt,name=Channel,proto3" json:"Channel,omitempty"`
	Group                string                    `protobuf:"bytes,4,opt,name=Group,proto3" json:"Group,omitempty"`
	EventsStoreTypeData  Subscribe_EventsStoreType `` /* 130-byte string literal not displayed */
	EventsStoreTypeValue int64                     `protobuf:"varint,6,opt,name=EventsStoreTypeValue,proto3" json:"EventsStoreTypeValue,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func NewPopulatedSubscribe 

func NewPopulatedSubscribe(r randyKubemqGo, easy bool) *Subscribe

func (*Subscribe) Descriptor 

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

func (*Subscribe) Equal 

func (this *Subscribe) Equal(that interface{}) bool

func (*Subscribe) GetChannel 

func (m *Subscribe) GetChannel() string

func (*Subscribe) GetClientID 

func (m *Subscribe) GetClientID() string

func (*Subscribe) GetEventsStoreTypeData 

func (m *Subscribe) GetEventsStoreTypeData() Subscribe_EventsStoreType

func (*Subscribe) GetEventsStoreTypeValue 

func (m *Subscribe) GetEventsStoreTypeValue() int64

func (*Subscribe) GetGroup 

func (m *Subscribe) GetGroup() string

func (*Subscribe) GetSubscribeTypeData 

func (m *Subscribe) GetSubscribeTypeData() Subscribe_SubscribeType

func (*Subscribe) GoString 

func (this *Subscribe) GoString() string

func (*Subscribe) Marshal 

func (m *Subscribe) Marshal() (dAtA []byte, err error)

func (*Subscribe) MarshalTo 

func (m *Subscribe) MarshalTo(dAtA []byte) (int, error)

func (*Subscribe) ProtoMessage 

func (*Subscribe) ProtoMessage()

func (*Subscribe) Reset 

func (m *Subscribe) Reset()

func (*Subscribe) Size 

func (m *Subscribe) Size() (n int)

func (*Subscribe) String 

func (this *Subscribe) String() string

func (*Subscribe) Unmarshal 

func (m *Subscribe) Unmarshal(dAtA []byte) error

func (*Subscribe) XXX_DiscardUnknown 

func (m *Subscribe) XXX_DiscardUnknown()

func (*Subscribe) XXX_Marshal 

func (m *Subscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Subscribe) XXX_Merge 

func (dst *Subscribe) XXX_Merge(src proto.Message)

func (*Subscribe) XXX_Size 

func (m *Subscribe) XXX_Size() int

func (*Subscribe) XXX_Unmarshal 

func (m *Subscribe) XXX_Unmarshal(b []byte) error

type Subscribe_EventsStoreType 

type Subscribe_EventsStoreType int32
const (
	EventsStoreTypeUndefined Subscribe_EventsStoreType = 0
	StartNewOnly             Subscribe_EventsStoreType = 1
	StartFromFirst           Subscribe_EventsStoreType = 2
	StartFromLast            Subscribe_EventsStoreType = 3
	StartAtSequence          Subscribe_EventsStoreType = 4
	StartAtTime              Subscribe_EventsStoreType = 5
	StartAtTimeDelta         Subscribe_EventsStoreType = 6
)

func (Subscribe_EventsStoreType) EnumDescriptor 

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

func (Subscribe_EventsStoreType) String 

func (x Subscribe_EventsStoreType) String() string

type Subscribe_SubscribeType 

type Subscribe_SubscribeType int32
const (
	SubscribeTypeUndefined Subscribe_SubscribeType = 0
	Events                 Subscribe_SubscribeType = 1
	EventsStore            Subscribe_SubscribeType = 2
	Commands               Subscribe_SubscribeType = 3
	Queries                Subscribe_SubscribeType = 4
)

func (Subscribe_SubscribeType) EnumDescriptor 

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

func (Subscribe_SubscribeType) String 

func (x Subscribe_SubscribeType) 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.