pb

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2019 License: Apache-2.0 Imports: 12 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 StreamRequestType_name = map[int32]string{
	0: "StreamRequestTypeUnknown",
	1: "ReceiveMessage",
	2: "AckMessage",
	3: "RejectMessage",
	4: "ModifyVisibility",
	5: "ResendMessage",
	6: "SendModifiedMessage",
}
View Source 
var StreamRequestType_value = map[string]int32{
	"StreamRequestTypeUnknown": 0,
	"ReceiveMessage":           1,
	"AckMessage":               2,
	"RejectMessage":            3,
	"ModifyVisibility":         4,
	"ResendMessage":            5,
	"SendModifiedMessage":      6,
}
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 AckAllQueueMessagesRequest added in v1.2.0 

type AckAllQueueMessagesRequest struct {
	RequestID            string   `protobuf:"bytes,1,opt,name=RequestID,proto3" json:"RequestID,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"`
	WaitTimeSeconds      int32    `protobuf:"varint,4,opt,name=WaitTimeSeconds,proto3" json:"WaitTimeSeconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedAckAllQueueMessagesRequest added in v1.2.0 

func NewPopulatedAckAllQueueMessagesRequest(r randyKubemqGo, easy bool) *AckAllQueueMessagesRequest

func (*AckAllQueueMessagesRequest) Descriptor added in v1.2.0 

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

func (*AckAllQueueMessagesRequest) Equal added in v1.2.0 

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

func (*AckAllQueueMessagesRequest) GetChannel added in v1.2.0 

func (m *AckAllQueueMessagesRequest) GetChannel() string

func (*AckAllQueueMessagesRequest) GetClientID added in v1.2.0 

func (m *AckAllQueueMessagesRequest) GetClientID() string

func (*AckAllQueueMessagesRequest) GetRequestID added in v1.2.0 

func (m *AckAllQueueMessagesRequest) GetRequestID() string

func (*AckAllQueueMessagesRequest) GetWaitTimeSeconds added in v1.2.0 

func (m *AckAllQueueMessagesRequest) GetWaitTimeSeconds() int32

func (*AckAllQueueMessagesRequest) GoString added in v1.2.0 

func (this *AckAllQueueMessagesRequest) GoString() string

func (*AckAllQueueMessagesRequest) Marshal added in v1.2.0 

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

func (*AckAllQueueMessagesRequest) MarshalTo added in v1.2.0 

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

func (*AckAllQueueMessagesRequest) ProtoMessage added in v1.2.0 

func (*AckAllQueueMessagesRequest) ProtoMessage()

func (*AckAllQueueMessagesRequest) Reset added in v1.2.0 

func (m *AckAllQueueMessagesRequest) Reset()

func (*AckAllQueueMessagesRequest) Size added in v1.2.0 

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

func (*AckAllQueueMessagesRequest) String added in v1.2.0 

func (this *AckAllQueueMessagesRequest) String() string

func (*AckAllQueueMessagesRequest) Unmarshal added in v1.2.0 

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

func (*AckAllQueueMessagesRequest) XXX_DiscardUnknown added in v1.2.0 

func (m *AckAllQueueMessagesRequest) XXX_DiscardUnknown()

func (*AckAllQueueMessagesRequest) XXX_Marshal added in v1.2.0 

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

func (*AckAllQueueMessagesRequest) XXX_Merge added in v1.2.0 

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

func (*AckAllQueueMessagesRequest) XXX_Size added in v1.2.0 

func (m *AckAllQueueMessagesRequest) XXX_Size() int

func (*AckAllQueueMessagesRequest) XXX_Unmarshal added in v1.2.0 

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

type AckAllQueueMessagesResponse added in v1.2.0 

type AckAllQueueMessagesResponse struct {
	RequestID            string   `protobuf:"bytes,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	AffectedMessages     uint64   `protobuf:"varint,2,opt,name=AffectedMessages,proto3" json:"AffectedMessages,omitempty"`
	IsError              bool     `protobuf:"varint,3,opt,name=IsError,proto3" json:"IsError,omitempty"`
	Error                string   `protobuf:"bytes,4,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedAckAllQueueMessagesResponse added in v1.2.0 

func NewPopulatedAckAllQueueMessagesResponse(r randyKubemqGo, easy bool) *AckAllQueueMessagesResponse

func (*AckAllQueueMessagesResponse) Descriptor added in v1.2.0 

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

func (*AckAllQueueMessagesResponse) Equal added in v1.2.0 

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

func (*AckAllQueueMessagesResponse) GetAffectedMessages added in v1.2.0 

func (m *AckAllQueueMessagesResponse) GetAffectedMessages() uint64

func (*AckAllQueueMessagesResponse) GetError added in v1.2.0 

func (m *AckAllQueueMessagesResponse) GetError() string

func (*AckAllQueueMessagesResponse) GetIsError added in v1.2.0 

func (m *AckAllQueueMessagesResponse) GetIsError() bool

func (*AckAllQueueMessagesResponse) GetRequestID added in v1.2.0 

func (m *AckAllQueueMessagesResponse) GetRequestID() string

func (*AckAllQueueMessagesResponse) GoString added in v1.2.0 

func (this *AckAllQueueMessagesResponse) GoString() string

func (*AckAllQueueMessagesResponse) Marshal added in v1.2.0 

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

func (*AckAllQueueMessagesResponse) MarshalTo added in v1.2.0 

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

func (*AckAllQueueMessagesResponse) ProtoMessage added in v1.2.0 

func (*AckAllQueueMessagesResponse) ProtoMessage()

func (*AckAllQueueMessagesResponse) Reset added in v1.2.0 

func (m *AckAllQueueMessagesResponse) Reset()

func (*AckAllQueueMessagesResponse) Size added in v1.2.0 

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

func (*AckAllQueueMessagesResponse) String added in v1.2.0 

func (this *AckAllQueueMessagesResponse) String() string

func (*AckAllQueueMessagesResponse) Unmarshal added in v1.2.0 

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

func (*AckAllQueueMessagesResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *AckAllQueueMessagesResponse) XXX_DiscardUnknown()

func (*AckAllQueueMessagesResponse) XXX_Marshal added in v1.2.0 

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

func (*AckAllQueueMessagesResponse) XXX_Merge added in v1.2.0 

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

func (*AckAllQueueMessagesResponse) XXX_Size added in v1.2.0 

func (m *AckAllQueueMessagesResponse) XXX_Size() int

func (*AckAllQueueMessagesResponse) XXX_Unmarshal added in v1.2.0 

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

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=EventID,proto3" json:"EventID,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"`
	Tags                 map[string]string `` /* 142-byte string literal not displayed */
	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) GetTags added in v1.2.0 

func (m *Event) GetTags() map[string]string

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=EventID,proto3" json:"EventID,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"`
	Tags                 map[string]string `` /* 142-byte string literal not displayed */
	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) GetTags added in v1.2.0 

func (m *EventReceive) GetTags() map[string]string

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)
	SendQueueMessage(ctx context.Context, in *QueueMessage, opts ...grpc.CallOption) (*SendQueueMessageResult, error)
	SendQueueMessagesBatch(ctx context.Context, in *QueueMessagesBatchRequest, opts ...grpc.CallOption) (*QueueMessagesBatchResponse, error)
	ReceiveQueueMessages(ctx context.Context, in *ReceiveQueueMessagesRequest, opts ...grpc.CallOption) (*ReceiveQueueMessagesResponse, error)
	StreamQueueMessage(ctx context.Context, opts ...grpc.CallOption) (Kubemq_StreamQueueMessageClient, error)
	AckAllQueueMessages(ctx context.Context, in *AckAllQueueMessagesRequest, opts ...grpc.CallOption) (*AckAllQueueMessagesResponse, error)
	Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PingResult, 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)
	SendQueueMessage(context.Context, *QueueMessage) (*SendQueueMessageResult, error)
	SendQueueMessagesBatch(context.Context, *QueueMessagesBatchRequest) (*QueueMessagesBatchResponse, error)
	ReceiveQueueMessages(context.Context, *ReceiveQueueMessagesRequest) (*ReceiveQueueMessagesResponse, error)
	StreamQueueMessage(Kubemq_StreamQueueMessageServer) error
	AckAllQueueMessages(context.Context, *AckAllQueueMessagesRequest) (*AckAllQueueMessagesResponse, error)
	Ping(context.Context, *Empty) (*PingResult, 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_StreamQueueMessageClient added in v1.2.0 

type Kubemq_StreamQueueMessageClient interface {
	Send(*StreamQueueMessagesRequest) error
	Recv() (*StreamQueueMessagesResponse, error)
	grpc.ClientStream
}

type Kubemq_StreamQueueMessageServer added in v1.2.0 

type Kubemq_StreamQueueMessageServer interface {
	Send(*StreamQueueMessagesResponse) error
	Recv() (*StreamQueueMessagesRequest, 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 PingResult added in v1.2.0 

type PingResult struct {
	Host                 string   `protobuf:"bytes,1,opt,name=Host,proto3" json:"Host,omitempty"`
	Version              string   `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
	ServerStartTime      int64    `protobuf:"varint,3,opt,name=ServerStartTime,proto3" json:"ServerStartTime,omitempty"`
	ServerUpTimeSeconds  int64    `protobuf:"varint,4,opt,name=ServerUpTimeSeconds,proto3" json:"ServerUpTimeSeconds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedPingResult added in v1.2.0 

func NewPopulatedPingResult(r randyKubemqGo, easy bool) *PingResult

func (*PingResult) Descriptor added in v1.2.0 

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

func (*PingResult) Equal added in v1.2.0 

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

func (*PingResult) GetHost added in v1.2.0 

func (m *PingResult) GetHost() string

func (*PingResult) GetServerStartTime added in v1.2.0 

func (m *PingResult) GetServerStartTime() int64

func (*PingResult) GetServerUpTimeSeconds added in v1.2.0 

func (m *PingResult) GetServerUpTimeSeconds() int64

func (*PingResult) GetVersion added in v1.2.0 

func (m *PingResult) GetVersion() string

func (*PingResult) GoString added in v1.2.0 

func (this *PingResult) GoString() string

func (*PingResult) Marshal added in v1.2.0 

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

func (*PingResult) MarshalTo added in v1.2.0 

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

func (*PingResult) ProtoMessage added in v1.2.0 

func (*PingResult) ProtoMessage()

func (*PingResult) Reset added in v1.2.0 

func (m *PingResult) Reset()

func (*PingResult) Size added in v1.2.0 

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

func (*PingResult) String added in v1.2.0 

func (this *PingResult) String() string

func (*PingResult) Unmarshal added in v1.2.0 

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

func (*PingResult) XXX_DiscardUnknown added in v1.2.0 

func (m *PingResult) XXX_DiscardUnknown()

func (*PingResult) XXX_Marshal added in v1.2.0 

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

func (*PingResult) XXX_Merge added in v1.2.0 

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

func (*PingResult) XXX_Size added in v1.2.0 

func (m *PingResult) XXX_Size() int

func (*PingResult) XXX_Unmarshal added in v1.2.0 

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

type QueueMessage added in v1.2.0 

type QueueMessage struct {
	MessageID            string                  `protobuf:"bytes,1,opt,name=MessageID,proto3" json:"MessageID,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"`
	Tags                 map[string]string       `` /* 142-byte string literal not displayed */
	Attributes           *QueueMessageAttributes `protobuf:"bytes,7,opt,name=Attributes" json:"Attributes,omitempty"`
	Policy               *QueueMessagePolicy     `protobuf:"bytes,8,opt,name=Policy" json:"Policy,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func NewPopulatedQueueMessage added in v1.2.0 

func NewPopulatedQueueMessage(r randyKubemqGo, easy bool) *QueueMessage

func (*QueueMessage) Descriptor added in v1.2.0 

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

func (*QueueMessage) Equal added in v1.2.0 

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

func (*QueueMessage) GetAttributes added in v1.2.0 

func (m *QueueMessage) GetAttributes() *QueueMessageAttributes

func (*QueueMessage) GetBody added in v1.2.0 

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

func (*QueueMessage) GetChannel added in v1.2.0 

func (m *QueueMessage) GetChannel() string

func (*QueueMessage) GetClientID added in v1.2.0 

func (m *QueueMessage) GetClientID() string

func (*QueueMessage) GetMessageID added in v1.2.0 

func (m *QueueMessage) GetMessageID() string

func (*QueueMessage) GetMetadata added in v1.2.0 

func (m *QueueMessage) GetMetadata() string

func (*QueueMessage) GetPolicy added in v1.2.0 

func (m *QueueMessage) GetPolicy() *QueueMessagePolicy

func (*QueueMessage) GetTags added in v1.2.0 

func (m *QueueMessage) GetTags() map[string]string

func (*QueueMessage) GoString added in v1.2.0 

func (this *QueueMessage) GoString() string

func (*QueueMessage) Marshal added in v1.2.0 

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

func (*QueueMessage) MarshalTo added in v1.2.0 

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

func (*QueueMessage) ProtoMessage added in v1.2.0 

func (*QueueMessage) ProtoMessage()

func (*QueueMessage) Reset added in v1.2.0 

func (m *QueueMessage) Reset()

func (*QueueMessage) Size added in v1.2.0 

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

func (*QueueMessage) String added in v1.2.0 

func (this *QueueMessage) String() string

func (*QueueMessage) Unmarshal added in v1.2.0 

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

func (*QueueMessage) XXX_DiscardUnknown added in v1.2.0 

func (m *QueueMessage) XXX_DiscardUnknown()

func (*QueueMessage) XXX_Marshal added in v1.2.0 

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

func (*QueueMessage) XXX_Merge added in v1.2.0 

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

func (*QueueMessage) XXX_Size added in v1.2.0 

func (m *QueueMessage) XXX_Size() int

func (*QueueMessage) XXX_Unmarshal added in v1.2.0 

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

type QueueMessageAttributes added in v1.2.0 

type QueueMessageAttributes struct {
	Timestamp            int64    `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Sequence             uint64   `protobuf:"varint,2,opt,name=Sequence,proto3" json:"Sequence,omitempty"`
	MD5OfBody            string   `protobuf:"bytes,3,opt,name=MD5OfBody,proto3" json:"MD5OfBody,omitempty"`
	ReceiveCount         int32    `protobuf:"varint,4,opt,name=ReceiveCount,proto3" json:"ReceiveCount,omitempty"`
	ReRouted             bool     `protobuf:"varint,5,opt,name=ReRouted,proto3" json:"ReRouted,omitempty"`
	ReRoutedFromQueue    string   `protobuf:"bytes,6,opt,name=ReRoutedFromQueue,proto3" json:"ReRoutedFromQueue,omitempty"`
	ExpirationAt         int64    `protobuf:"varint,7,opt,name=ExpirationAt,proto3" json:"ExpirationAt,omitempty"`
	DelayedTo            int64    `protobuf:"varint,8,opt,name=DelayedTo,proto3" json:"DelayedTo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedQueueMessageAttributes added in v1.2.0 

func NewPopulatedQueueMessageAttributes(r randyKubemqGo, easy bool) *QueueMessageAttributes

func (*QueueMessageAttributes) Descriptor added in v1.2.0 

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

func (*QueueMessageAttributes) Equal added in v1.2.0 

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

func (*QueueMessageAttributes) GetDelayedTo added in v1.2.0 

func (m *QueueMessageAttributes) GetDelayedTo() int64

func (*QueueMessageAttributes) GetExpirationAt added in v1.2.0 

func (m *QueueMessageAttributes) GetExpirationAt() int64

func (*QueueMessageAttributes) GetMD5OfBody added in v1.2.0 

func (m *QueueMessageAttributes) GetMD5OfBody() string

func (*QueueMessageAttributes) GetReRouted added in v1.2.0 

func (m *QueueMessageAttributes) GetReRouted() bool

func (*QueueMessageAttributes) GetReRoutedFromQueue added in v1.2.0 

func (m *QueueMessageAttributes) GetReRoutedFromQueue() string

func (*QueueMessageAttributes) GetReceiveCount added in v1.2.0 

func (m *QueueMessageAttributes) GetReceiveCount() int32

func (*QueueMessageAttributes) GetSequence added in v1.2.0 

func (m *QueueMessageAttributes) GetSequence() uint64

func (*QueueMessageAttributes) GetTimestamp added in v1.2.0 

func (m *QueueMessageAttributes) GetTimestamp() int64

func (*QueueMessageAttributes) GoString added in v1.2.0 

func (this *QueueMessageAttributes) GoString() string

func (*QueueMessageAttributes) Marshal added in v1.2.0 

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

func (*QueueMessageAttributes) MarshalTo added in v1.2.0 

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

func (*QueueMessageAttributes) ProtoMessage added in v1.2.0 

func (*QueueMessageAttributes) ProtoMessage()

func (*QueueMessageAttributes) Reset added in v1.2.0 

func (m *QueueMessageAttributes) Reset()

func (*QueueMessageAttributes) Size added in v1.2.0 

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

func (*QueueMessageAttributes) String added in v1.2.0 

func (this *QueueMessageAttributes) String() string

func (*QueueMessageAttributes) Unmarshal added in v1.2.0 

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

func (*QueueMessageAttributes) XXX_DiscardUnknown added in v1.2.0 

func (m *QueueMessageAttributes) XXX_DiscardUnknown()

func (*QueueMessageAttributes) XXX_Marshal added in v1.2.0 

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

func (*QueueMessageAttributes) XXX_Merge added in v1.2.0 

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

func (*QueueMessageAttributes) XXX_Size added in v1.2.0 

func (m *QueueMessageAttributes) XXX_Size() int

func (*QueueMessageAttributes) XXX_Unmarshal added in v1.2.0 

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

type QueueMessagePolicy added in v1.2.0 

type QueueMessagePolicy struct {
	ExpirationSeconds    int32    `protobuf:"varint,1,opt,name=ExpirationSeconds,proto3" json:"ExpirationSeconds,omitempty"`
	DelaySeconds         int32    `protobuf:"varint,2,opt,name=DelaySeconds,proto3" json:"DelaySeconds,omitempty"`
	MaxReceiveCount      int32    `protobuf:"varint,3,opt,name=MaxReceiveCount,proto3" json:"MaxReceiveCount,omitempty"`
	MaxReceiveQueue      string   `protobuf:"bytes,4,opt,name=MaxReceiveQueue,proto3" json:"MaxReceiveQueue,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedQueueMessagePolicy added in v1.2.0 

func NewPopulatedQueueMessagePolicy(r randyKubemqGo, easy bool) *QueueMessagePolicy

func (*QueueMessagePolicy) Descriptor added in v1.2.0 

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

func (*QueueMessagePolicy) Equal added in v1.2.0 

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

func (*QueueMessagePolicy) GetDelaySeconds added in v1.2.0 

func (m *QueueMessagePolicy) GetDelaySeconds() int32

func (*QueueMessagePolicy) GetExpirationSeconds added in v1.2.0 

func (m *QueueMessagePolicy) GetExpirationSeconds() int32

func (*QueueMessagePolicy) GetMaxReceiveCount added in v1.2.0 

func (m *QueueMessagePolicy) GetMaxReceiveCount() int32

func (*QueueMessagePolicy) GetMaxReceiveQueue added in v1.2.0 

func (m *QueueMessagePolicy) GetMaxReceiveQueue() string

func (*QueueMessagePolicy) GoString added in v1.2.0 

func (this *QueueMessagePolicy) GoString() string

func (*QueueMessagePolicy) Marshal added in v1.2.0 

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

func (*QueueMessagePolicy) MarshalTo added in v1.2.0 

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

func (*QueueMessagePolicy) ProtoMessage added in v1.2.0 

func (*QueueMessagePolicy) ProtoMessage()

func (*QueueMessagePolicy) Reset added in v1.2.0 

func (m *QueueMessagePolicy) Reset()

func (*QueueMessagePolicy) Size added in v1.2.0 

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

func (*QueueMessagePolicy) String added in v1.2.0 

func (this *QueueMessagePolicy) String() string

func (*QueueMessagePolicy) Unmarshal added in v1.2.0 

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

func (*QueueMessagePolicy) XXX_DiscardUnknown added in v1.2.0 

func (m *QueueMessagePolicy) XXX_DiscardUnknown()

func (*QueueMessagePolicy) XXX_Marshal added in v1.2.0 

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

func (*QueueMessagePolicy) XXX_Merge added in v1.2.0 

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

func (*QueueMessagePolicy) XXX_Size added in v1.2.0 

func (m *QueueMessagePolicy) XXX_Size() int

func (*QueueMessagePolicy) XXX_Unmarshal added in v1.2.0 

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

type QueueMessagesBatchRequest added in v1.2.0 

type QueueMessagesBatchRequest struct {
	BatchID              string          `protobuf:"bytes,1,opt,name=BatchID,proto3" json:"BatchID,omitempty"`
	Messages             []*QueueMessage `protobuf:"bytes,2,rep,name=Messages" json:"Messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func NewPopulatedQueueMessagesBatchRequest added in v1.2.0 

func NewPopulatedQueueMessagesBatchRequest(r randyKubemqGo, easy bool) *QueueMessagesBatchRequest

func (*QueueMessagesBatchRequest) Descriptor added in v1.2.0 

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

func (*QueueMessagesBatchRequest) Equal added in v1.2.0 

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

func (*QueueMessagesBatchRequest) GetBatchID added in v1.2.0 

func (m *QueueMessagesBatchRequest) GetBatchID() string

func (*QueueMessagesBatchRequest) GetMessages added in v1.2.0 

func (m *QueueMessagesBatchRequest) GetMessages() []*QueueMessage

func (*QueueMessagesBatchRequest) GoString added in v1.2.0 

func (this *QueueMessagesBatchRequest) GoString() string

func (*QueueMessagesBatchRequest) Marshal added in v1.2.0 

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

func (*QueueMessagesBatchRequest) MarshalTo added in v1.2.0 

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

func (*QueueMessagesBatchRequest) ProtoMessage added in v1.2.0 

func (*QueueMessagesBatchRequest) ProtoMessage()

func (*QueueMessagesBatchRequest) Reset added in v1.2.0 

func (m *QueueMessagesBatchRequest) Reset()

func (*QueueMessagesBatchRequest) Size added in v1.2.0 

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

func (*QueueMessagesBatchRequest) String added in v1.2.0 

func (this *QueueMessagesBatchRequest) String() string

func (*QueueMessagesBatchRequest) Unmarshal added in v1.2.0 

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

func (*QueueMessagesBatchRequest) XXX_DiscardUnknown added in v1.2.0 

func (m *QueueMessagesBatchRequest) XXX_DiscardUnknown()

func (*QueueMessagesBatchRequest) XXX_Marshal added in v1.2.0 

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

func (*QueueMessagesBatchRequest) XXX_Merge added in v1.2.0 

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

func (*QueueMessagesBatchRequest) XXX_Size added in v1.2.0 

func (m *QueueMessagesBatchRequest) XXX_Size() int

func (*QueueMessagesBatchRequest) XXX_Unmarshal added in v1.2.0 

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

type QueueMessagesBatchResponse added in v1.2.0 

type QueueMessagesBatchResponse struct {
	BatchID              string                    `protobuf:"bytes,1,opt,name=BatchID,proto3" json:"BatchID,omitempty"`
	Results              []*SendQueueMessageResult `protobuf:"bytes,2,rep,name=Results" json:"Results,omitempty"`
	HaveErrors           bool                      `protobuf:"varint,3,opt,name=HaveErrors,proto3" json:"HaveErrors,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func NewPopulatedQueueMessagesBatchResponse added in v1.2.0 

func NewPopulatedQueueMessagesBatchResponse(r randyKubemqGo, easy bool) *QueueMessagesBatchResponse

func (*QueueMessagesBatchResponse) Descriptor added in v1.2.0 

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

func (*QueueMessagesBatchResponse) Equal added in v1.2.0 

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

func (*QueueMessagesBatchResponse) GetBatchID added in v1.2.0 

func (m *QueueMessagesBatchResponse) GetBatchID() string

func (*QueueMessagesBatchResponse) GetHaveErrors added in v1.2.0 

func (m *QueueMessagesBatchResponse) GetHaveErrors() bool

func (*QueueMessagesBatchResponse) GetResults added in v1.2.0 

func (m *QueueMessagesBatchResponse) GetResults() []*SendQueueMessageResult

func (*QueueMessagesBatchResponse) GoString added in v1.2.0 

func (this *QueueMessagesBatchResponse) GoString() string

func (*QueueMessagesBatchResponse) Marshal added in v1.2.0 

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

func (*QueueMessagesBatchResponse) MarshalTo added in v1.2.0 

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

func (*QueueMessagesBatchResponse) ProtoMessage added in v1.2.0 

func (*QueueMessagesBatchResponse) ProtoMessage()

func (*QueueMessagesBatchResponse) Reset added in v1.2.0 

func (m *QueueMessagesBatchResponse) Reset()

func (*QueueMessagesBatchResponse) Size added in v1.2.0 

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

func (*QueueMessagesBatchResponse) String added in v1.2.0 

func (this *QueueMessagesBatchResponse) String() string

func (*QueueMessagesBatchResponse) Unmarshal added in v1.2.0 

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

func (*QueueMessagesBatchResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *QueueMessagesBatchResponse) XXX_DiscardUnknown()

func (*QueueMessagesBatchResponse) XXX_Marshal added in v1.2.0 

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

func (*QueueMessagesBatchResponse) XXX_Merge added in v1.2.0 

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

func (*QueueMessagesBatchResponse) XXX_Size added in v1.2.0 

func (m *QueueMessagesBatchResponse) XXX_Size() int

func (*QueueMessagesBatchResponse) XXX_Unmarshal added in v1.2.0 

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

type ReceiveQueueMessagesRequest added in v1.2.0 

type ReceiveQueueMessagesRequest struct {
	RequestID            string   `protobuf:"bytes,1,opt,name=RequestID,proto3" json:"RequestID,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"`
	MaxNumberOfMessages  int32    `protobuf:"varint,4,opt,name=MaxNumberOfMessages,proto3" json:"MaxNumberOfMessages,omitempty"`
	WaitTimeSeconds      int32    `protobuf:"varint,5,opt,name=WaitTimeSeconds,proto3" json:"WaitTimeSeconds,omitempty"`
	IsPeak               bool     `protobuf:"varint,6,opt,name=IsPeak,proto3" json:"IsPeak,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedReceiveQueueMessagesRequest added in v1.2.0 

func NewPopulatedReceiveQueueMessagesRequest(r randyKubemqGo, easy bool) *ReceiveQueueMessagesRequest

func (*ReceiveQueueMessagesRequest) Descriptor added in v1.2.0 

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

func (*ReceiveQueueMessagesRequest) Equal added in v1.2.0 

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

func (*ReceiveQueueMessagesRequest) GetChannel added in v1.2.0 

func (m *ReceiveQueueMessagesRequest) GetChannel() string

func (*ReceiveQueueMessagesRequest) GetClientID added in v1.2.0 

func (m *ReceiveQueueMessagesRequest) GetClientID() string

func (*ReceiveQueueMessagesRequest) GetIsPeak added in v1.2.0 

func (m *ReceiveQueueMessagesRequest) GetIsPeak() bool

func (*ReceiveQueueMessagesRequest) GetMaxNumberOfMessages added in v1.2.0 

func (m *ReceiveQueueMessagesRequest) GetMaxNumberOfMessages() int32

func (*ReceiveQueueMessagesRequest) GetRequestID added in v1.2.0 

func (m *ReceiveQueueMessagesRequest) GetRequestID() string

func (*ReceiveQueueMessagesRequest) GetWaitTimeSeconds added in v1.2.0 

func (m *ReceiveQueueMessagesRequest) GetWaitTimeSeconds() int32

func (*ReceiveQueueMessagesRequest) GoString added in v1.2.0 

func (this *ReceiveQueueMessagesRequest) GoString() string

func (*ReceiveQueueMessagesRequest) Marshal added in v1.2.0 

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

func (*ReceiveQueueMessagesRequest) MarshalTo added in v1.2.0 

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

func (*ReceiveQueueMessagesRequest) ProtoMessage added in v1.2.0 

func (*ReceiveQueueMessagesRequest) ProtoMessage()

func (*ReceiveQueueMessagesRequest) Reset added in v1.2.0 

func (m *ReceiveQueueMessagesRequest) Reset()

func (*ReceiveQueueMessagesRequest) Size added in v1.2.0 

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

func (*ReceiveQueueMessagesRequest) String added in v1.2.0 

func (this *ReceiveQueueMessagesRequest) String() string

func (*ReceiveQueueMessagesRequest) Unmarshal added in v1.2.0 

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

func (*ReceiveQueueMessagesRequest) XXX_DiscardUnknown added in v1.2.0 

func (m *ReceiveQueueMessagesRequest) XXX_DiscardUnknown()

func (*ReceiveQueueMessagesRequest) XXX_Marshal added in v1.2.0 

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

func (*ReceiveQueueMessagesRequest) XXX_Merge added in v1.2.0 

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

func (*ReceiveQueueMessagesRequest) XXX_Size added in v1.2.0 

func (m *ReceiveQueueMessagesRequest) XXX_Size() int

func (*ReceiveQueueMessagesRequest) XXX_Unmarshal added in v1.2.0 

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

type ReceiveQueueMessagesResponse added in v1.2.0 

type ReceiveQueueMessagesResponse struct {
	RequestID            string          `protobuf:"bytes,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	Messages             []*QueueMessage `protobuf:"bytes,2,rep,name=Messages" json:"Messages,omitempty"`
	MessagesReceived     int32           `protobuf:"varint,3,opt,name=MessagesReceived,proto3" json:"MessagesReceived,omitempty"`
	MessagesExpired      int32           `protobuf:"varint,4,opt,name=MessagesExpired,proto3" json:"MessagesExpired,omitempty"`
	IsPeak               bool            `protobuf:"varint,5,opt,name=IsPeak,proto3" json:"IsPeak,omitempty"`
	IsError              bool            `protobuf:"varint,6,opt,name=IsError,proto3" json:"IsError,omitempty"`
	Error                string          `protobuf:"bytes,7,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func NewPopulatedReceiveQueueMessagesResponse added in v1.2.0 

func NewPopulatedReceiveQueueMessagesResponse(r randyKubemqGo, easy bool) *ReceiveQueueMessagesResponse

func (*ReceiveQueueMessagesResponse) Descriptor added in v1.2.0 

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

func (*ReceiveQueueMessagesResponse) Equal added in v1.2.0 

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

func (*ReceiveQueueMessagesResponse) GetError added in v1.2.0 

func (m *ReceiveQueueMessagesResponse) GetError() string

func (*ReceiveQueueMessagesResponse) GetIsError added in v1.2.0 

func (m *ReceiveQueueMessagesResponse) GetIsError() bool

func (*ReceiveQueueMessagesResponse) GetIsPeak added in v1.2.0 

func (m *ReceiveQueueMessagesResponse) GetIsPeak() bool

func (*ReceiveQueueMessagesResponse) GetMessages added in v1.2.0 

func (m *ReceiveQueueMessagesResponse) GetMessages() []*QueueMessage

func (*ReceiveQueueMessagesResponse) GetMessagesExpired added in v1.2.0 

func (m *ReceiveQueueMessagesResponse) GetMessagesExpired() int32

func (*ReceiveQueueMessagesResponse) GetMessagesReceived added in v1.2.0 

func (m *ReceiveQueueMessagesResponse) GetMessagesReceived() int32

func (*ReceiveQueueMessagesResponse) GetRequestID added in v1.2.0 

func (m *ReceiveQueueMessagesResponse) GetRequestID() string

func (*ReceiveQueueMessagesResponse) GoString added in v1.2.0 

func (this *ReceiveQueueMessagesResponse) GoString() string

func (*ReceiveQueueMessagesResponse) Marshal added in v1.2.0 

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

func (*ReceiveQueueMessagesResponse) MarshalTo added in v1.2.0 

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

func (*ReceiveQueueMessagesResponse) ProtoMessage added in v1.2.0 

func (*ReceiveQueueMessagesResponse) ProtoMessage()

func (*ReceiveQueueMessagesResponse) Reset added in v1.2.0 

func (m *ReceiveQueueMessagesResponse) Reset()

func (*ReceiveQueueMessagesResponse) Size added in v1.2.0 

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

func (*ReceiveQueueMessagesResponse) String added in v1.2.0 

func (this *ReceiveQueueMessagesResponse) String() string

func (*ReceiveQueueMessagesResponse) Unmarshal added in v1.2.0 

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

func (*ReceiveQueueMessagesResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *ReceiveQueueMessagesResponse) XXX_DiscardUnknown()

func (*ReceiveQueueMessagesResponse) XXX_Marshal added in v1.2.0 

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

func (*ReceiveQueueMessagesResponse) XXX_Merge added in v1.2.0 

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

func (*ReceiveQueueMessagesResponse) XXX_Size added in v1.2.0 

func (m *ReceiveQueueMessagesResponse) XXX_Size() int

func (*ReceiveQueueMessagesResponse) XXX_Unmarshal added in v1.2.0 

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

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"`
	Tags                 map[string]string   `` /* 143-byte string literal not displayed */
	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) GetTags added in v1.2.0 

func (m *Request) GetTags() map[string]string

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"`
	Tags                 map[string]string `` /* 143-byte string literal not displayed */
	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) GetTags added in v1.2.0 

func (m *Response) GetTags() map[string]string

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=EventID,proto3" json:"EventID,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 SendQueueMessageResult added in v1.2.0 

type SendQueueMessageResult struct {
	MessageID            string   `protobuf:"bytes,1,opt,name=MessageID,proto3" json:"MessageID,omitempty"`
	SentAt               int64    `protobuf:"varint,2,opt,name=SentAt,proto3" json:"SentAt,omitempty"`
	ExpirationAt         int64    `protobuf:"varint,3,opt,name=ExpirationAt,proto3" json:"ExpirationAt,omitempty"`
	DelayedTo            int64    `protobuf:"varint,4,opt,name=DelayedTo,proto3" json:"DelayedTo,omitempty"`
	IsError              bool     `protobuf:"varint,5,opt,name=IsError,proto3" json:"IsError,omitempty"`
	Error                string   `protobuf:"bytes,6,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedSendQueueMessageResult added in v1.2.0 

func NewPopulatedSendQueueMessageResult(r randyKubemqGo, easy bool) *SendQueueMessageResult

func (*SendQueueMessageResult) Descriptor added in v1.2.0 

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

func (*SendQueueMessageResult) Equal added in v1.2.0 

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

func (*SendQueueMessageResult) GetDelayedTo added in v1.2.0 

func (m *SendQueueMessageResult) GetDelayedTo() int64

func (*SendQueueMessageResult) GetError added in v1.2.0 

func (m *SendQueueMessageResult) GetError() string

func (*SendQueueMessageResult) GetExpirationAt added in v1.2.0 

func (m *SendQueueMessageResult) GetExpirationAt() int64

func (*SendQueueMessageResult) GetIsError added in v1.2.0 

func (m *SendQueueMessageResult) GetIsError() bool

func (*SendQueueMessageResult) GetMessageID added in v1.2.0 

func (m *SendQueueMessageResult) GetMessageID() string

func (*SendQueueMessageResult) GetSentAt added in v1.2.0 

func (m *SendQueueMessageResult) GetSentAt() int64

func (*SendQueueMessageResult) GoString added in v1.2.0 

func (this *SendQueueMessageResult) GoString() string

func (*SendQueueMessageResult) Marshal added in v1.2.0 

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

func (*SendQueueMessageResult) MarshalTo added in v1.2.0 

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

func (*SendQueueMessageResult) ProtoMessage added in v1.2.0 

func (*SendQueueMessageResult) ProtoMessage()

func (*SendQueueMessageResult) Reset added in v1.2.0 

func (m *SendQueueMessageResult) Reset()

func (*SendQueueMessageResult) Size added in v1.2.0 

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

func (*SendQueueMessageResult) String added in v1.2.0 

func (this *SendQueueMessageResult) String() string

func (*SendQueueMessageResult) Unmarshal added in v1.2.0 

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

func (*SendQueueMessageResult) XXX_DiscardUnknown added in v1.2.0 

func (m *SendQueueMessageResult) XXX_DiscardUnknown()

func (*SendQueueMessageResult) XXX_Marshal added in v1.2.0 

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

func (*SendQueueMessageResult) XXX_Merge added in v1.2.0 

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

func (*SendQueueMessageResult) XXX_Size added in v1.2.0 

func (m *SendQueueMessageResult) XXX_Size() int

func (*SendQueueMessageResult) XXX_Unmarshal added in v1.2.0 

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

type StreamQueueMessagesRequest added in v1.2.0 

type StreamQueueMessagesRequest struct {
	RequestID             string            `protobuf:"bytes,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	ClientID              string            `protobuf:"bytes,2,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	StreamRequestTypeData StreamRequestType `` /* 126-byte string literal not displayed */
	Channel               string            `protobuf:"bytes,4,opt,name=Channel,proto3" json:"Channel,omitempty"`
	VisibilitySeconds     int32             `protobuf:"varint,5,opt,name=VisibilitySeconds,proto3" json:"VisibilitySeconds,omitempty"`
	WaitTimeSeconds       int32             `protobuf:"varint,6,opt,name=WaitTimeSeconds,proto3" json:"WaitTimeSeconds,omitempty"`
	RefSequence           uint64            `protobuf:"varint,7,opt,name=RefSequence,proto3" json:"RefSequence,omitempty"`
	ModifiedMessage       *QueueMessage     `protobuf:"bytes,8,opt,name=ModifiedMessage" json:"ModifiedMessage,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}          `json:"-"`
	XXX_sizecache         int32             `json:"-"`
}

func NewPopulatedStreamQueueMessagesRequest added in v1.2.0 

func NewPopulatedStreamQueueMessagesRequest(r randyKubemqGo, easy bool) *StreamQueueMessagesRequest

func (*StreamQueueMessagesRequest) Descriptor added in v1.2.0 

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

func (*StreamQueueMessagesRequest) Equal added in v1.2.0 

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

func (*StreamQueueMessagesRequest) GetChannel added in v1.2.0 

func (m *StreamQueueMessagesRequest) GetChannel() string

func (*StreamQueueMessagesRequest) GetClientID added in v1.2.0 

func (m *StreamQueueMessagesRequest) GetClientID() string

func (*StreamQueueMessagesRequest) GetModifiedMessage added in v1.2.0 

func (m *StreamQueueMessagesRequest) GetModifiedMessage() *QueueMessage

func (*StreamQueueMessagesRequest) GetRefSequence added in v1.2.0 

func (m *StreamQueueMessagesRequest) GetRefSequence() uint64

func (*StreamQueueMessagesRequest) GetRequestID added in v1.2.0 

func (m *StreamQueueMessagesRequest) GetRequestID() string

func (*StreamQueueMessagesRequest) GetStreamRequestTypeData added in v1.2.0 

func (m *StreamQueueMessagesRequest) GetStreamRequestTypeData() StreamRequestType

func (*StreamQueueMessagesRequest) GetVisibilitySeconds added in v1.2.0 

func (m *StreamQueueMessagesRequest) GetVisibilitySeconds() int32

func (*StreamQueueMessagesRequest) GetWaitTimeSeconds added in v1.2.0 

func (m *StreamQueueMessagesRequest) GetWaitTimeSeconds() int32

func (*StreamQueueMessagesRequest) GoString added in v1.2.0 

func (this *StreamQueueMessagesRequest) GoString() string

func (*StreamQueueMessagesRequest) Marshal added in v1.2.0 

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

func (*StreamQueueMessagesRequest) MarshalTo added in v1.2.0 

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

func (*StreamQueueMessagesRequest) ProtoMessage added in v1.2.0 

func (*StreamQueueMessagesRequest) ProtoMessage()

func (*StreamQueueMessagesRequest) Reset added in v1.2.0 

func (m *StreamQueueMessagesRequest) Reset()

func (*StreamQueueMessagesRequest) Size added in v1.2.0 

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

func (*StreamQueueMessagesRequest) String added in v1.2.0 

func (this *StreamQueueMessagesRequest) String() string

func (*StreamQueueMessagesRequest) Unmarshal added in v1.2.0 

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

func (*StreamQueueMessagesRequest) XXX_DiscardUnknown added in v1.2.0 

func (m *StreamQueueMessagesRequest) XXX_DiscardUnknown()

func (*StreamQueueMessagesRequest) XXX_Marshal added in v1.2.0 

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

func (*StreamQueueMessagesRequest) XXX_Merge added in v1.2.0 

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

func (*StreamQueueMessagesRequest) XXX_Size added in v1.2.0 

func (m *StreamQueueMessagesRequest) XXX_Size() int

func (*StreamQueueMessagesRequest) XXX_Unmarshal added in v1.2.0 

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

type StreamQueueMessagesResponse added in v1.2.0 

type StreamQueueMessagesResponse struct {
	RequestID             string            `protobuf:"bytes,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	StreamRequestTypeData StreamRequestType `` /* 126-byte string literal not displayed */
	Message               *QueueMessage     `protobuf:"bytes,3,opt,name=Message" json:"Message,omitempty"`
	IsError               bool              `protobuf:"varint,4,opt,name=IsError,proto3" json:"IsError,omitempty"`
	Error                 string            `protobuf:"bytes,5,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}          `json:"-"`
	XXX_sizecache         int32             `json:"-"`
}

func NewPopulatedStreamQueueMessagesResponse added in v1.2.0 

func NewPopulatedStreamQueueMessagesResponse(r randyKubemqGo, easy bool) *StreamQueueMessagesResponse

func (*StreamQueueMessagesResponse) Descriptor added in v1.2.0 

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

func (*StreamQueueMessagesResponse) Equal added in v1.2.0 

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

func (*StreamQueueMessagesResponse) GetError added in v1.2.0 

func (m *StreamQueueMessagesResponse) GetError() string

func (*StreamQueueMessagesResponse) GetIsError added in v1.2.0 

func (m *StreamQueueMessagesResponse) GetIsError() bool

func (*StreamQueueMessagesResponse) GetMessage added in v1.2.0 

func (m *StreamQueueMessagesResponse) GetMessage() *QueueMessage

func (*StreamQueueMessagesResponse) GetRequestID added in v1.2.0 

func (m *StreamQueueMessagesResponse) GetRequestID() string

func (*StreamQueueMessagesResponse) GetStreamRequestTypeData added in v1.2.0 

func (m *StreamQueueMessagesResponse) GetStreamRequestTypeData() StreamRequestType

func (*StreamQueueMessagesResponse) GoString added in v1.2.0 

func (this *StreamQueueMessagesResponse) GoString() string

func (*StreamQueueMessagesResponse) Marshal added in v1.2.0 

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

func (*StreamQueueMessagesResponse) MarshalTo added in v1.2.0 

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

func (*StreamQueueMessagesResponse) ProtoMessage added in v1.2.0 

func (*StreamQueueMessagesResponse) ProtoMessage()

func (*StreamQueueMessagesResponse) Reset added in v1.2.0 

func (m *StreamQueueMessagesResponse) Reset()

func (*StreamQueueMessagesResponse) Size added in v1.2.0 

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

func (*StreamQueueMessagesResponse) String added in v1.2.0 

func (this *StreamQueueMessagesResponse) String() string

func (*StreamQueueMessagesResponse) Unmarshal added in v1.2.0 

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

func (*StreamQueueMessagesResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *StreamQueueMessagesResponse) XXX_DiscardUnknown()

func (*StreamQueueMessagesResponse) XXX_Marshal added in v1.2.0 

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

func (*StreamQueueMessagesResponse) XXX_Merge added in v1.2.0 

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

func (*StreamQueueMessagesResponse) XXX_Size added in v1.2.0 

func (m *StreamQueueMessagesResponse) XXX_Size() int

func (*StreamQueueMessagesResponse) XXX_Unmarshal added in v1.2.0 

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

type StreamRequestType added in v1.2.0 

type StreamRequestType int32
const (
	StreamRequestTypeUnknown StreamRequestType = 0
	ReceiveMessage           StreamRequestType = 1
	AckMessage               StreamRequestType = 2
	RejectMessage            StreamRequestType = 3
	ModifyVisibility         StreamRequestType = 4
	ResendMessage            StreamRequestType = 5
	SendModifiedMessage      StreamRequestType = 6
)

func (StreamRequestType) EnumDescriptor added in v1.2.0 

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

func (StreamRequestType) String added in v1.2.0 

func (x StreamRequestType) String() string

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.