kubemq

package
v1.3.1 Latest Latest
Warning

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

 Go to latest Published: May 27, 2021 License: Apache-2.0 Imports: 11 Imported by: 19

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 QueuesDownstreamRequestType_name = map[int32]string{
	0:  "PollRequestTypeUnknown",
	1:  "Get",
	2:  "AckAll",
	3:  "AckRange",
	4:  "NAckAll",
	5:  "NAckRange",
	6:  "ReQueueAll",
	7:  "ReQueueRange",
	8:  "ActiveOffsets",
	9:  "TransactionStatus",
	10: "CloseByClient",
	11: "CloseByServer",
}
View Source 
var QueuesDownstreamRequestType_value = map[string]int32{
	"PollRequestTypeUnknown": 0,
	"Get":                    1,
	"AckAll":                 2,
	"AckRange":               3,
	"NAckAll":                4,
	"NAckRange":              5,
	"ReQueueAll":             6,
	"ReQueueRange":           7,
	"ActiveOffsets":          8,
	"TransactionStatus":      9,
	"CloseByClient":          10,
	"CloseByServer":          11,
}
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,
}
View Source 
var TopicsDownstreamRequestType_name = map[int32]string{
	0: "DownstreamRequestTypeUndefined",
	1: "DownstreamRequestTypeSubscriptionRequest",
	2: "DownstreamRequestTypeSubscriptionEvent",
}
View Source 
var TopicsDownstreamRequestType_value = map[string]int32{
	"DownstreamRequestTypeUndefined":           0,
	"DownstreamRequestTypeSubscriptionRequest": 1,
	"DownstreamRequestTypeSubscriptionEvent":   2,
}
View Source 
var TopicsSubscriptionEventType_name = map[int32]string{
	0: "SubscriptionEventTypeUndefined",
	1: "SubscriptionEventTypeSubscribe",
	2: "SubscriptionEventTypeReSync",
	3: "SubscriptionEventTypeReSyncComplete",
	4: "SubscriptionEventTypeHeartbeat",
	5: "SubscriptionEventTypeLeave",
	6: "SubscriptionEventTypeGroupState",
}
View Source 
var TopicsSubscriptionEventType_value = map[string]int32{
	"SubscriptionEventTypeUndefined":      0,
	"SubscriptionEventTypeSubscribe":      1,
	"SubscriptionEventTypeReSync":         2,
	"SubscriptionEventTypeReSyncComplete": 3,
	"SubscriptionEventTypeHeartbeat":      4,
	"SubscriptionEventTypeLeave":          5,
	"SubscriptionEventTypeGroupState":     6,
}
View Source 
var TopicsSubscriptionOffsetType_name = map[int32]string{
	0: "SubscriptionOffsetTypeUndefined",
	1: "StartNewOnly",
	2: "StartFromFirst",
	3: "StartFromLast",
	4: "StartAtSequence",
	5: "StartAtTime",
	6: "StartAtTimeDelta",
}
View Source 
var TopicsSubscriptionOffsetType_value = map[string]int32{
	"SubscriptionOffsetTypeUndefined": 0,
	"StartNewOnly":                    1,
	"StartFromFirst":                  2,
	"StartFromLast":                   3,
	"StartAtSequence":                 4,
	"StartAtTime":                     5,
	"StartAtTimeDelta":                6,
}
View Source 
var TopicsSubscriptionRequestType_name = map[int32]string{
	0: "SubscriptionRequestTypeUndefined",
	1: "SubscriptionRequestTypeJoin",
	2: "SubscriptionRequestTypeLeave",
}
View Source 
var TopicsSubscriptionRequestType_value = map[string]int32{
	"SubscriptionRequestTypeUndefined": 0,
	"SubscriptionRequestTypeJoin":      1,
	"SubscriptionRequestTypeLeave":     2,
}
View Source 
var TopicsSubscriptionStrategyType_name = map[int32]string{
	0: "SubscriptionStrategyTypeUndefined",
	1: "Range",
	2: "RoundRobin",
	3: "Sticky",
}
View Source 
var TopicsSubscriptionStrategyType_value = map[string]int32{
	"SubscriptionStrategyTypeUndefined": 0,
	"Range":                             1,
	"RoundRobin":                        2,
	"Sticky":                            3,
}
View Source 
var TopicsUpstreamRequestType_name = map[int32]string{
	0: "TopicsUpstreamRequestUnknown",
	1: "FireAndForget",
	2: "SendAsync",
	3: "SendSync",
}
View Source 
var TopicsUpstreamRequestType_value = map[string]int32{
	"TopicsUpstreamRequestUnknown": 0,
	"FireAndForget":                1,
	"SendAsync":                    2,
	"SendSync":                     3,
}

Functions

func RegisterKubemqServer 

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

Types

type AckAllQueueMessagesRequest added in v1.1.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_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedAckAllQueueMessagesRequest added in v1.1.0 

func NewPopulatedAckAllQueueMessagesRequest(r randyKubemqGo, easy bool) *AckAllQueueMessagesRequest

func (*AckAllQueueMessagesRequest) Descriptor added in v1.1.0 

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

func (*AckAllQueueMessagesRequest) Equal added in v1.1.0 

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

func (*AckAllQueueMessagesRequest) GetChannel added in v1.1.0 

func (m *AckAllQueueMessagesRequest) GetChannel() string

func (*AckAllQueueMessagesRequest) GetClientID added in v1.1.0 

func (m *AckAllQueueMessagesRequest) GetClientID() string

func (*AckAllQueueMessagesRequest) GetRequestID added in v1.1.0 

func (m *AckAllQueueMessagesRequest) GetRequestID() string

func (*AckAllQueueMessagesRequest) GetWaitTimeSeconds added in v1.1.0 

func (m *AckAllQueueMessagesRequest) GetWaitTimeSeconds() int32

func (*AckAllQueueMessagesRequest) GoString added in v1.1.0 

func (this *AckAllQueueMessagesRequest) GoString() string

func (*AckAllQueueMessagesRequest) Marshal added in v1.1.0 

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

func (*AckAllQueueMessagesRequest) MarshalTo added in v1.1.0 

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

func (*AckAllQueueMessagesRequest) ProtoMessage added in v1.1.0 

func (*AckAllQueueMessagesRequest) ProtoMessage()

func (*AckAllQueueMessagesRequest) Reset added in v1.1.0 

func (m *AckAllQueueMessagesRequest) Reset()

func (*AckAllQueueMessagesRequest) Size added in v1.1.0 

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

func (*AckAllQueueMessagesRequest) String added in v1.1.0 

func (this *AckAllQueueMessagesRequest) String() string

func (*AckAllQueueMessagesRequest) Unmarshal added in v1.1.0 

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

func (*AckAllQueueMessagesRequest) XXX_DiscardUnknown added in v1.1.0 

func (m *AckAllQueueMessagesRequest) XXX_DiscardUnknown()

func (*AckAllQueueMessagesRequest) XXX_Marshal added in v1.1.0 

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

func (*AckAllQueueMessagesRequest) XXX_Merge added in v1.1.0 

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

func (*AckAllQueueMessagesRequest) XXX_Size added in v1.1.0 

func (m *AckAllQueueMessagesRequest) XXX_Size() int

func (*AckAllQueueMessagesRequest) XXX_Unmarshal added in v1.1.0 

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

type AckAllQueueMessagesResponse added in v1.1.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_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedAckAllQueueMessagesResponse added in v1.1.0 

func NewPopulatedAckAllQueueMessagesResponse(r randyKubemqGo, easy bool) *AckAllQueueMessagesResponse

func (*AckAllQueueMessagesResponse) Descriptor added in v1.1.0 

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

func (*AckAllQueueMessagesResponse) Equal added in v1.1.0 

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

func (*AckAllQueueMessagesResponse) GetAffectedMessages added in v1.1.0 

func (m *AckAllQueueMessagesResponse) GetAffectedMessages() uint64

func (*AckAllQueueMessagesResponse) GetError added in v1.1.0 

func (m *AckAllQueueMessagesResponse) GetError() string

func (*AckAllQueueMessagesResponse) GetIsError added in v1.1.0 

func (m *AckAllQueueMessagesResponse) GetIsError() bool

func (*AckAllQueueMessagesResponse) GetRequestID added in v1.1.0 

func (m *AckAllQueueMessagesResponse) GetRequestID() string

func (*AckAllQueueMessagesResponse) GoString added in v1.1.0 

func (this *AckAllQueueMessagesResponse) GoString() string

func (*AckAllQueueMessagesResponse) Marshal added in v1.1.0 

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

func (*AckAllQueueMessagesResponse) MarshalTo added in v1.1.0 

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

func (*AckAllQueueMessagesResponse) ProtoMessage added in v1.1.0 

func (*AckAllQueueMessagesResponse) ProtoMessage()

func (*AckAllQueueMessagesResponse) Reset added in v1.1.0 

func (m *AckAllQueueMessagesResponse) Reset()

func (*AckAllQueueMessagesResponse) Size added in v1.1.0 

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

func (*AckAllQueueMessagesResponse) String added in v1.1.0 

func (this *AckAllQueueMessagesResponse) String() string

func (*AckAllQueueMessagesResponse) Unmarshal added in v1.1.0 

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

func (*AckAllQueueMessagesResponse) XXX_DiscardUnknown added in v1.1.0 

func (m *AckAllQueueMessagesResponse) XXX_DiscardUnknown()

func (*AckAllQueueMessagesResponse) XXX_Marshal added in v1.1.0 

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

func (*AckAllQueueMessagesResponse) XXX_Merge added in v1.1.0 

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

func (*AckAllQueueMessagesResponse) XXX_Size added in v1.1.0 

func (m *AckAllQueueMessagesResponse) XXX_Size() int

func (*AckAllQueueMessagesResponse) XXX_Unmarshal added in v1.1.0 

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

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `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 (m *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 `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `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.1.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 (m *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 `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `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.1.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 (m *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)
	QueuesDownstream(ctx context.Context, opts ...grpc.CallOption) (Kubemq_QueuesDownstreamClient, error)
	QueuesUpstream(ctx context.Context, opts ...grpc.CallOption) (Kubemq_QueuesUpstreamClient, error)
	QueuesInfo(ctx context.Context, in *QueuesInfoRequest, opts ...grpc.CallOption) (*QueuesInfoResponse, error)
}

KubemqClient is the client API for Kubemq service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

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)
	QueuesDownstream(Kubemq_QueuesDownstreamServer) error
	QueuesUpstream(Kubemq_QueuesUpstreamServer) error
	QueuesInfo(context.Context, *QueuesInfoRequest) (*QueuesInfoResponse, error)
}

KubemqServer is the server API for Kubemq service.

type Kubemq_QueuesDownstreamClient added in v1.3.0 

type Kubemq_QueuesDownstreamClient interface {
	Send(*QueuesDownstreamRequest) error
	Recv() (*QueuesDownstreamResponse, error)
	grpc.ClientStream
}

type Kubemq_QueuesDownstreamServer added in v1.3.0 

type Kubemq_QueuesDownstreamServer interface {
	Send(*QueuesDownstreamResponse) error
	Recv() (*QueuesDownstreamRequest, error)
	grpc.ServerStream
}

type Kubemq_QueuesUpstreamClient added in v1.3.0 

type Kubemq_QueuesUpstreamClient interface {
	Send(*QueuesUpstreamRequest) error
	Recv() (*QueuesUpstreamResponse, error)
	grpc.ClientStream
}

type Kubemq_QueuesUpstreamServer added in v1.3.0 

type Kubemq_QueuesUpstreamServer interface {
	Send(*QueuesUpstreamResponse) error
	Recv() (*QueuesUpstreamRequest, error)
	grpc.ServerStream
}

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.1.0 

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

type Kubemq_StreamQueueMessageServer added in v1.1.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.1.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_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedPingResult added in v1.1.0 

func NewPopulatedPingResult(r randyKubemqGo, easy bool) *PingResult

func (*PingResult) Descriptor added in v1.1.0 

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

func (*PingResult) Equal added in v1.1.0 

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

func (*PingResult) GetHost added in v1.1.0 

func (m *PingResult) GetHost() string

func (*PingResult) GetServerStartTime added in v1.1.0 

func (m *PingResult) GetServerStartTime() int64

func (*PingResult) GetServerUpTimeSeconds added in v1.1.0 

func (m *PingResult) GetServerUpTimeSeconds() int64

func (*PingResult) GetVersion added in v1.1.0 

func (m *PingResult) GetVersion() string

func (*PingResult) GoString added in v1.1.0 

func (this *PingResult) GoString() string

func (*PingResult) Marshal added in v1.1.0 

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

func (*PingResult) MarshalTo added in v1.1.0 

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

func (*PingResult) ProtoMessage added in v1.1.0 

func (*PingResult) ProtoMessage()

func (*PingResult) Reset added in v1.1.0 

func (m *PingResult) Reset()

func (*PingResult) Size added in v1.1.0 

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

func (*PingResult) String added in v1.1.0 

func (this *PingResult) String() string

func (*PingResult) Unmarshal added in v1.1.0 

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

func (*PingResult) XXX_DiscardUnknown added in v1.1.0 

func (m *PingResult) XXX_DiscardUnknown()

func (*PingResult) XXX_Marshal added in v1.1.0 

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

func (*PingResult) XXX_Merge added in v1.1.0 

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

func (*PingResult) XXX_Size added in v1.1.0 

func (m *PingResult) XXX_Size() int

func (*PingResult) XXX_Unmarshal added in v1.1.0 

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

type QueueInfo added in v1.3.1 

type QueueInfo struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Messages             int64    `protobuf:"varint,2,opt,name=Messages,proto3" json:"Messages,omitempty"`
	Bytes                int64    `protobuf:"varint,3,opt,name=Bytes,proto3" json:"Bytes,omitempty"`
	FirstSequence        int64    `protobuf:"varint,4,opt,name=FirstSequence,proto3" json:"FirstSequence,omitempty"`
	LastSequence         int64    `protobuf:"varint,5,opt,name=LastSequence,proto3" json:"LastSequence,omitempty"`
	Sent                 int64    `protobuf:"varint,6,opt,name=Sent,proto3" json:"Sent,omitempty"`
	Delivered            int64    `protobuf:"varint,7,opt,name=Delivered,proto3" json:"Delivered,omitempty"`
	Waiting              int64    `protobuf:"varint,8,opt,name=Waiting,proto3" json:"Waiting,omitempty"`
	Subscribers          int64    `protobuf:"varint,9,opt,name=Subscribers,proto3" json:"Subscribers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedQueueInfo added in v1.3.1 

func NewPopulatedQueueInfo(r randyKubemqGo, easy bool) *QueueInfo

func (*QueueInfo) Descriptor added in v1.3.1 

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

func (*QueueInfo) Equal added in v1.3.1 

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

func (*QueueInfo) GetBytes added in v1.3.1 

func (m *QueueInfo) GetBytes() int64

func (*QueueInfo) GetDelivered added in v1.3.1 

func (m *QueueInfo) GetDelivered() int64

func (*QueueInfo) GetFirstSequence added in v1.3.1 

func (m *QueueInfo) GetFirstSequence() int64

func (*QueueInfo) GetLastSequence added in v1.3.1 

func (m *QueueInfo) GetLastSequence() int64

func (*QueueInfo) GetMessages added in v1.3.1 

func (m *QueueInfo) GetMessages() int64

func (*QueueInfo) GetName added in v1.3.1 

func (m *QueueInfo) GetName() string

func (*QueueInfo) GetSent added in v1.3.1 

func (m *QueueInfo) GetSent() int64

func (*QueueInfo) GetSubscribers added in v1.3.1 

func (m *QueueInfo) GetSubscribers() int64

func (*QueueInfo) GetWaiting added in v1.3.1 

func (m *QueueInfo) GetWaiting() int64

func (*QueueInfo) GoString added in v1.3.1 

func (this *QueueInfo) GoString() string

func (*QueueInfo) Marshal added in v1.3.1 

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

func (*QueueInfo) MarshalTo added in v1.3.1 

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

func (*QueueInfo) ProtoMessage added in v1.3.1 

func (*QueueInfo) ProtoMessage()

func (*QueueInfo) Reset added in v1.3.1 

func (m *QueueInfo) Reset()

func (*QueueInfo) Size added in v1.3.1 

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

func (*QueueInfo) String added in v1.3.1 

func (this *QueueInfo) String() string

func (*QueueInfo) Unmarshal added in v1.3.1 

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

func (*QueueInfo) XXX_DiscardUnknown added in v1.3.1 

func (m *QueueInfo) XXX_DiscardUnknown()

func (*QueueInfo) XXX_Marshal added in v1.3.1 

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

func (*QueueInfo) XXX_Merge added in v1.3.1 

func (m *QueueInfo) XXX_Merge(src proto.Message)

func (*QueueInfo) XXX_Size added in v1.3.1 

func (m *QueueInfo) XXX_Size() int

func (*QueueInfo) XXX_Unmarshal added in v1.3.1 

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

type QueueMessage added in v1.1.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       `` /* 149-byte string literal not displayed */
	Attributes           *QueueMessageAttributes `protobuf:"bytes,7,opt,name=Attributes,proto3" json:"Attributes,omitempty"`
	Policy               *QueueMessagePolicy     `protobuf:"bytes,8,opt,name=Policy,proto3" json:"Policy,omitempty"`
	Topic                string                  `protobuf:"bytes,9,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Partition            int32                   `protobuf:"varint,10,opt,name=Partition,proto3" json:"Partition,omitempty"`
	PartitionKey         string                  `protobuf:"bytes,11,opt,name=PartitionKey,proto3" json:"PartitionKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func NewPopulatedQueueMessage added in v1.1.0 

func NewPopulatedQueueMessage(r randyKubemqGo, easy bool) *QueueMessage

func (*QueueMessage) Descriptor added in v1.1.0 

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

func (*QueueMessage) Equal added in v1.1.0 

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

func (*QueueMessage) GetAttributes added in v1.1.0 

func (m *QueueMessage) GetAttributes() *QueueMessageAttributes

func (*QueueMessage) GetBody added in v1.1.0 

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

func (*QueueMessage) GetChannel added in v1.1.0 

func (m *QueueMessage) GetChannel() string

func (*QueueMessage) GetClientID added in v1.1.0 

func (m *QueueMessage) GetClientID() string

func (*QueueMessage) GetMessageID added in v1.1.0 

func (m *QueueMessage) GetMessageID() string

func (*QueueMessage) GetMetadata added in v1.1.0 

func (m *QueueMessage) GetMetadata() string

func (*QueueMessage) GetPartition added in v1.3.1 

func (m *QueueMessage) GetPartition() int32

func (*QueueMessage) GetPartitionKey added in v1.3.1 

func (m *QueueMessage) GetPartitionKey() string

func (*QueueMessage) GetPolicy added in v1.1.0 

func (m *QueueMessage) GetPolicy() *QueueMessagePolicy

func (*QueueMessage) GetTags added in v1.1.0 

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

func (*QueueMessage) GetTopic added in v1.3.1 

func (m *QueueMessage) GetTopic() string

func (*QueueMessage) GoString added in v1.1.0 

func (this *QueueMessage) GoString() string

func (*QueueMessage) Marshal added in v1.1.0 

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

func (*QueueMessage) MarshalTo added in v1.1.0 

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

func (*QueueMessage) ProtoMessage added in v1.1.0 

func (*QueueMessage) ProtoMessage()

func (*QueueMessage) Reset added in v1.1.0 

func (m *QueueMessage) Reset()

func (*QueueMessage) Size added in v1.1.0 

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

func (*QueueMessage) String added in v1.1.0 

func (this *QueueMessage) String() string

func (*QueueMessage) Unmarshal added in v1.1.0 

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

func (*QueueMessage) XXX_DiscardUnknown added in v1.1.0 

func (m *QueueMessage) XXX_DiscardUnknown()

func (*QueueMessage) XXX_Marshal added in v1.1.0 

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

func (*QueueMessage) XXX_Merge added in v1.1.0 

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

func (*QueueMessage) XXX_Size added in v1.1.0 

func (m *QueueMessage) XXX_Size() int

func (*QueueMessage) XXX_Unmarshal added in v1.1.0 

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

type QueueMessageAttributes added in v1.1.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_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedQueueMessageAttributes added in v1.1.0 

func NewPopulatedQueueMessageAttributes(r randyKubemqGo, easy bool) *QueueMessageAttributes

func (*QueueMessageAttributes) Descriptor added in v1.1.0 

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

func (*QueueMessageAttributes) Equal added in v1.1.0 

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

func (*QueueMessageAttributes) GetDelayedTo added in v1.1.0 

func (m *QueueMessageAttributes) GetDelayedTo() int64

func (*QueueMessageAttributes) GetExpirationAt added in v1.1.0 

func (m *QueueMessageAttributes) GetExpirationAt() int64

func (*QueueMessageAttributes) GetMD5OfBody added in v1.1.0 

func (m *QueueMessageAttributes) GetMD5OfBody() string

func (*QueueMessageAttributes) GetReRouted added in v1.1.0 

func (m *QueueMessageAttributes) GetReRouted() bool

func (*QueueMessageAttributes) GetReRoutedFromQueue added in v1.1.0 

func (m *QueueMessageAttributes) GetReRoutedFromQueue() string

func (*QueueMessageAttributes) GetReceiveCount added in v1.1.0 

func (m *QueueMessageAttributes) GetReceiveCount() int32

func (*QueueMessageAttributes) GetSequence added in v1.1.0 

func (m *QueueMessageAttributes) GetSequence() uint64

func (*QueueMessageAttributes) GetTimestamp added in v1.1.0 

func (m *QueueMessageAttributes) GetTimestamp() int64

func (*QueueMessageAttributes) GoString added in v1.1.0 

func (this *QueueMessageAttributes) GoString() string

func (*QueueMessageAttributes) Marshal added in v1.1.0 

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

func (*QueueMessageAttributes) MarshalTo added in v1.1.0 

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

func (*QueueMessageAttributes) ProtoMessage added in v1.1.0 

func (*QueueMessageAttributes) ProtoMessage()

func (*QueueMessageAttributes) Reset added in v1.1.0 

func (m *QueueMessageAttributes) Reset()

func (*QueueMessageAttributes) Size added in v1.1.0 

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

func (*QueueMessageAttributes) String added in v1.1.0 

func (this *QueueMessageAttributes) String() string

func (*QueueMessageAttributes) Unmarshal added in v1.1.0 

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

func (*QueueMessageAttributes) XXX_DiscardUnknown added in v1.1.0 

func (m *QueueMessageAttributes) XXX_DiscardUnknown()

func (*QueueMessageAttributes) XXX_Marshal added in v1.1.0 

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

func (*QueueMessageAttributes) XXX_Merge added in v1.1.0 

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

func (*QueueMessageAttributes) XXX_Size added in v1.1.0 

func (m *QueueMessageAttributes) XXX_Size() int

func (*QueueMessageAttributes) XXX_Unmarshal added in v1.1.0 

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

type QueueMessagePolicy added in v1.1.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_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedQueueMessagePolicy added in v1.1.0 

func NewPopulatedQueueMessagePolicy(r randyKubemqGo, easy bool) *QueueMessagePolicy

func (*QueueMessagePolicy) Descriptor added in v1.1.0 

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

func (*QueueMessagePolicy) Equal added in v1.1.0 

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

func (*QueueMessagePolicy) GetDelaySeconds added in v1.1.0 

func (m *QueueMessagePolicy) GetDelaySeconds() int32

func (*QueueMessagePolicy) GetExpirationSeconds added in v1.1.0 

func (m *QueueMessagePolicy) GetExpirationSeconds() int32

func (*QueueMessagePolicy) GetMaxReceiveCount added in v1.1.0 

func (m *QueueMessagePolicy) GetMaxReceiveCount() int32

func (*QueueMessagePolicy) GetMaxReceiveQueue added in v1.1.0 

func (m *QueueMessagePolicy) GetMaxReceiveQueue() string

func (*QueueMessagePolicy) GoString added in v1.1.0 

func (this *QueueMessagePolicy) GoString() string

func (*QueueMessagePolicy) Marshal added in v1.1.0 

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

func (*QueueMessagePolicy) MarshalTo added in v1.1.0 

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

func (*QueueMessagePolicy) ProtoMessage added in v1.1.0 

func (*QueueMessagePolicy) ProtoMessage()

func (*QueueMessagePolicy) Reset added in v1.1.0 

func (m *QueueMessagePolicy) Reset()

func (*QueueMessagePolicy) Size added in v1.1.0 

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

func (*QueueMessagePolicy) String added in v1.1.0 

func (this *QueueMessagePolicy) String() string

func (*QueueMessagePolicy) Unmarshal added in v1.1.0 

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

func (*QueueMessagePolicy) XXX_DiscardUnknown added in v1.1.0 

func (m *QueueMessagePolicy) XXX_DiscardUnknown()

func (*QueueMessagePolicy) XXX_Marshal added in v1.1.0 

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

func (*QueueMessagePolicy) XXX_Merge added in v1.1.0 

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

func (*QueueMessagePolicy) XXX_Size added in v1.1.0 

func (m *QueueMessagePolicy) XXX_Size() int

func (*QueueMessagePolicy) XXX_Unmarshal added in v1.1.0 

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

type QueueMessagesBatchRequest added in v1.1.0 

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

func NewPopulatedQueueMessagesBatchRequest added in v1.1.0 

func NewPopulatedQueueMessagesBatchRequest(r randyKubemqGo, easy bool) *QueueMessagesBatchRequest

func (*QueueMessagesBatchRequest) Descriptor added in v1.1.0 

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

func (*QueueMessagesBatchRequest) Equal added in v1.1.0 

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

func (*QueueMessagesBatchRequest) GetBatchID added in v1.1.0 

func (m *QueueMessagesBatchRequest) GetBatchID() string

func (*QueueMessagesBatchRequest) GetMessages added in v1.1.0 

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

func (*QueueMessagesBatchRequest) GoString added in v1.1.0 

func (this *QueueMessagesBatchRequest) GoString() string

func (*QueueMessagesBatchRequest) Marshal added in v1.1.0 

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

func (*QueueMessagesBatchRequest) MarshalTo added in v1.1.0 

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

func (*QueueMessagesBatchRequest) ProtoMessage added in v1.1.0 

func (*QueueMessagesBatchRequest) ProtoMessage()

func (*QueueMessagesBatchRequest) Reset added in v1.1.0 

func (m *QueueMessagesBatchRequest) Reset()

func (*QueueMessagesBatchRequest) Size added in v1.1.0 

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

func (*QueueMessagesBatchRequest) String added in v1.1.0 

func (this *QueueMessagesBatchRequest) String() string

func (*QueueMessagesBatchRequest) Unmarshal added in v1.1.0 

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

func (*QueueMessagesBatchRequest) XXX_DiscardUnknown added in v1.1.0 

func (m *QueueMessagesBatchRequest) XXX_DiscardUnknown()

func (*QueueMessagesBatchRequest) XXX_Marshal added in v1.1.0 

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

func (*QueueMessagesBatchRequest) XXX_Merge added in v1.1.0 

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

func (*QueueMessagesBatchRequest) XXX_Size added in v1.1.0 

func (m *QueueMessagesBatchRequest) XXX_Size() int

func (*QueueMessagesBatchRequest) XXX_Unmarshal added in v1.1.0 

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

type QueueMessagesBatchResponse added in v1.1.0 

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

func NewPopulatedQueueMessagesBatchResponse added in v1.1.0 

func NewPopulatedQueueMessagesBatchResponse(r randyKubemqGo, easy bool) *QueueMessagesBatchResponse

func (*QueueMessagesBatchResponse) Descriptor added in v1.1.0 

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

func (*QueueMessagesBatchResponse) Equal added in v1.1.0 

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

func (*QueueMessagesBatchResponse) GetBatchID added in v1.1.0 

func (m *QueueMessagesBatchResponse) GetBatchID() string

func (*QueueMessagesBatchResponse) GetHaveErrors added in v1.1.0 

func (m *QueueMessagesBatchResponse) GetHaveErrors() bool

func (*QueueMessagesBatchResponse) GetResults added in v1.1.0 

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

func (*QueueMessagesBatchResponse) GoString added in v1.1.0 

func (this *QueueMessagesBatchResponse) GoString() string

func (*QueueMessagesBatchResponse) Marshal added in v1.1.0 

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

func (*QueueMessagesBatchResponse) MarshalTo added in v1.1.0 

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

func (*QueueMessagesBatchResponse) ProtoMessage added in v1.1.0 

func (*QueueMessagesBatchResponse) ProtoMessage()

func (*QueueMessagesBatchResponse) Reset added in v1.1.0 

func (m *QueueMessagesBatchResponse) Reset()

func (*QueueMessagesBatchResponse) Size added in v1.1.0 

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

func (*QueueMessagesBatchResponse) String added in v1.1.0 

func (this *QueueMessagesBatchResponse) String() string

func (*QueueMessagesBatchResponse) Unmarshal added in v1.1.0 

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

func (*QueueMessagesBatchResponse) XXX_DiscardUnknown added in v1.1.0 

func (m *QueueMessagesBatchResponse) XXX_DiscardUnknown()

func (*QueueMessagesBatchResponse) XXX_Marshal added in v1.1.0 

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

func (*QueueMessagesBatchResponse) XXX_Merge added in v1.1.0 

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

func (*QueueMessagesBatchResponse) XXX_Size added in v1.1.0 

func (m *QueueMessagesBatchResponse) XXX_Size() int

func (*QueueMessagesBatchResponse) XXX_Unmarshal added in v1.1.0 

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

type QueuesDownstreamRequest added in v1.3.0 

type QueuesDownstreamRequest 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"`
	RequestTypeData      QueuesDownstreamRequestType `protobuf:"varint,3,opt,name=RequestTypeData,proto3,enum=kubemq.QueuesDownstreamRequestType" json:"RequestTypeData,omitempty"`
	Channel              string                      `protobuf:"bytes,4,opt,name=Channel,proto3" json:"Channel,omitempty"`
	MaxItems             int32                       `protobuf:"varint,5,opt,name=MaxItems,proto3" json:"MaxItems,omitempty"`
	WaitTimeout          int32                       `protobuf:"varint,6,opt,name=WaitTimeout,proto3" json:"WaitTimeout,omitempty"`
	AutoAck              bool                        `protobuf:"varint,7,opt,name=AutoAck,proto3" json:"AutoAck,omitempty"`
	ReQueueChannel       string                      `protobuf:"bytes,8,opt,name=ReQueueChannel,proto3" json:"ReQueueChannel,omitempty"`
	SequenceRange        []int64                     `protobuf:"varint,9,rep,packed,name=SequenceRange,proto3" json:"SequenceRange,omitempty"`
	RefTransactionId     string                      `protobuf:"bytes,10,opt,name=RefTransactionId,proto3" json:"RefTransactionId,omitempty"`
	Metadata             map[string]string           `` /* 158-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func NewPopulatedQueuesDownstreamRequest added in v1.3.0 

func NewPopulatedQueuesDownstreamRequest(r randyKubemqGo, easy bool) *QueuesDownstreamRequest

func (*QueuesDownstreamRequest) Descriptor added in v1.3.0 

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

func (*QueuesDownstreamRequest) Equal added in v1.3.0 

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

func (*QueuesDownstreamRequest) GetAutoAck added in v1.3.0 

func (m *QueuesDownstreamRequest) GetAutoAck() bool

func (*QueuesDownstreamRequest) GetChannel added in v1.3.0 

func (m *QueuesDownstreamRequest) GetChannel() string

func (*QueuesDownstreamRequest) GetClientID added in v1.3.0 

func (m *QueuesDownstreamRequest) GetClientID() string

func (*QueuesDownstreamRequest) GetMaxItems added in v1.3.0 

func (m *QueuesDownstreamRequest) GetMaxItems() int32

func (*QueuesDownstreamRequest) GetMetadata added in v1.3.0 

func (m *QueuesDownstreamRequest) GetMetadata() map[string]string

func (*QueuesDownstreamRequest) GetReQueueChannel added in v1.3.0 

func (m *QueuesDownstreamRequest) GetReQueueChannel() string

func (*QueuesDownstreamRequest) GetRefTransactionId added in v1.3.0 

func (m *QueuesDownstreamRequest) GetRefTransactionId() string

func (*QueuesDownstreamRequest) GetRequestID added in v1.3.0 

func (m *QueuesDownstreamRequest) GetRequestID() string

func (*QueuesDownstreamRequest) GetRequestTypeData added in v1.3.0 

func (m *QueuesDownstreamRequest) GetRequestTypeData() QueuesDownstreamRequestType

func (*QueuesDownstreamRequest) GetSequenceRange added in v1.3.0 

func (m *QueuesDownstreamRequest) GetSequenceRange() []int64

func (*QueuesDownstreamRequest) GetWaitTimeout added in v1.3.0 

func (m *QueuesDownstreamRequest) GetWaitTimeout() int32

func (*QueuesDownstreamRequest) GoString added in v1.3.0 

func (this *QueuesDownstreamRequest) GoString() string

func (*QueuesDownstreamRequest) Marshal added in v1.3.0 

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

func (*QueuesDownstreamRequest) MarshalTo added in v1.3.0 

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

func (*QueuesDownstreamRequest) ProtoMessage added in v1.3.0 

func (*QueuesDownstreamRequest) ProtoMessage()

func (*QueuesDownstreamRequest) Reset added in v1.3.0 

func (m *QueuesDownstreamRequest) Reset()

func (*QueuesDownstreamRequest) Size added in v1.3.0 

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

func (*QueuesDownstreamRequest) String added in v1.3.0 

func (this *QueuesDownstreamRequest) String() string

func (*QueuesDownstreamRequest) Unmarshal added in v1.3.0 

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

func (*QueuesDownstreamRequest) XXX_DiscardUnknown added in v1.3.0 

func (m *QueuesDownstreamRequest) XXX_DiscardUnknown()

func (*QueuesDownstreamRequest) XXX_Marshal added in v1.3.0 

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

func (*QueuesDownstreamRequest) XXX_Merge added in v1.3.0 

func (m *QueuesDownstreamRequest) XXX_Merge(src proto.Message)

func (*QueuesDownstreamRequest) XXX_Size added in v1.3.0 

func (m *QueuesDownstreamRequest) XXX_Size() int

func (*QueuesDownstreamRequest) XXX_Unmarshal added in v1.3.0 

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

type QueuesDownstreamRequestType added in v1.3.0 

type QueuesDownstreamRequestType int32
const (
	QueuesDownstreamRequestType_PollRequestTypeUnknown QueuesDownstreamRequestType = 0
	QueuesDownstreamRequestType_Get                    QueuesDownstreamRequestType = 1
	QueuesDownstreamRequestType_AckAll                 QueuesDownstreamRequestType = 2
	QueuesDownstreamRequestType_AckRange               QueuesDownstreamRequestType = 3
	QueuesDownstreamRequestType_NAckAll                QueuesDownstreamRequestType = 4
	QueuesDownstreamRequestType_NAckRange              QueuesDownstreamRequestType = 5
	QueuesDownstreamRequestType_ReQueueAll             QueuesDownstreamRequestType = 6
	QueuesDownstreamRequestType_ReQueueRange           QueuesDownstreamRequestType = 7
	QueuesDownstreamRequestType_ActiveOffsets          QueuesDownstreamRequestType = 8
	QueuesDownstreamRequestType_TransactionStatus      QueuesDownstreamRequestType = 9
	QueuesDownstreamRequestType_CloseByClient          QueuesDownstreamRequestType = 10
	QueuesDownstreamRequestType_CloseByServer          QueuesDownstreamRequestType = 11
)

func (QueuesDownstreamRequestType) EnumDescriptor added in v1.3.0 

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

func (QueuesDownstreamRequestType) String added in v1.3.0 

func (x QueuesDownstreamRequestType) String() string

type QueuesDownstreamResponse added in v1.3.0 

type QueuesDownstreamResponse struct {
	TransactionId        string                      `protobuf:"bytes,1,opt,name=TransactionId,proto3" json:"TransactionId,omitempty"`
	RefRequestId         string                      `protobuf:"bytes,2,opt,name=RefRequestId,proto3" json:"RefRequestId,omitempty"`
	RequestTypeData      QueuesDownstreamRequestType `protobuf:"varint,3,opt,name=RequestTypeData,proto3,enum=kubemq.QueuesDownstreamRequestType" json:"RequestTypeData,omitempty"`
	Messages             []*QueueMessage             `protobuf:"bytes,4,rep,name=Messages,proto3" json:"Messages,omitempty"`
	ActiveOffsets        []int64                     `protobuf:"varint,5,rep,packed,name=ActiveOffsets,proto3" json:"ActiveOffsets,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"`
	TransactionComplete  bool                        `protobuf:"varint,8,opt,name=TransactionComplete,proto3" json:"TransactionComplete,omitempty"`
	Metadata             map[string]string           `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func NewPopulatedQueuesDownstreamResponse added in v1.3.0 

func NewPopulatedQueuesDownstreamResponse(r randyKubemqGo, easy bool) *QueuesDownstreamResponse

func (*QueuesDownstreamResponse) Descriptor added in v1.3.0 

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

func (*QueuesDownstreamResponse) Equal added in v1.3.0 

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

func (*QueuesDownstreamResponse) GetActiveOffsets added in v1.3.0 

func (m *QueuesDownstreamResponse) GetActiveOffsets() []int64

func (*QueuesDownstreamResponse) GetError added in v1.3.0 

func (m *QueuesDownstreamResponse) GetError() string

func (*QueuesDownstreamResponse) GetIsError added in v1.3.0 

func (m *QueuesDownstreamResponse) GetIsError() bool

func (*QueuesDownstreamResponse) GetMessages added in v1.3.0 

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

func (*QueuesDownstreamResponse) GetMetadata added in v1.3.0 

func (m *QueuesDownstreamResponse) GetMetadata() map[string]string

func (*QueuesDownstreamResponse) GetRefRequestId added in v1.3.0 

func (m *QueuesDownstreamResponse) GetRefRequestId() string

func (*QueuesDownstreamResponse) GetRequestTypeData added in v1.3.0 

func (m *QueuesDownstreamResponse) GetRequestTypeData() QueuesDownstreamRequestType

func (*QueuesDownstreamResponse) GetTransactionComplete added in v1.3.0 

func (m *QueuesDownstreamResponse) GetTransactionComplete() bool

func (*QueuesDownstreamResponse) GetTransactionId added in v1.3.0 

func (m *QueuesDownstreamResponse) GetTransactionId() string

func (*QueuesDownstreamResponse) GoString added in v1.3.0 

func (this *QueuesDownstreamResponse) GoString() string

func (*QueuesDownstreamResponse) Marshal added in v1.3.0 

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

func (*QueuesDownstreamResponse) MarshalTo added in v1.3.0 

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

func (*QueuesDownstreamResponse) ProtoMessage added in v1.3.0 

func (*QueuesDownstreamResponse) ProtoMessage()

func (*QueuesDownstreamResponse) Reset added in v1.3.0 

func (m *QueuesDownstreamResponse) Reset()

func (*QueuesDownstreamResponse) Size added in v1.3.0 

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

func (*QueuesDownstreamResponse) String added in v1.3.0 

func (this *QueuesDownstreamResponse) String() string

func (*QueuesDownstreamResponse) Unmarshal added in v1.3.0 

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

func (*QueuesDownstreamResponse) XXX_DiscardUnknown added in v1.3.0 

func (m *QueuesDownstreamResponse) XXX_DiscardUnknown()

func (*QueuesDownstreamResponse) XXX_Marshal added in v1.3.0 

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

func (*QueuesDownstreamResponse) XXX_Merge added in v1.3.0 

func (m *QueuesDownstreamResponse) XXX_Merge(src proto.Message)

func (*QueuesDownstreamResponse) XXX_Size added in v1.3.0 

func (m *QueuesDownstreamResponse) XXX_Size() int

func (*QueuesDownstreamResponse) XXX_Unmarshal added in v1.3.0 

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

type QueuesInfo added in v1.3.1 

type QueuesInfo struct {
	TotalQueue           int32        `protobuf:"varint,1,opt,name=TotalQueue,proto3" json:"TotalQueue,omitempty"`
	Sent                 int64        `protobuf:"varint,2,opt,name=Sent,proto3" json:"Sent,omitempty"`
	Delivered            int64        `protobuf:"varint,3,opt,name=Delivered,proto3" json:"Delivered,omitempty"`
	Waiting              int64        `protobuf:"varint,4,opt,name=Waiting,proto3" json:"Waiting,omitempty"`
	Queues               []*QueueInfo `protobuf:"bytes,5,rep,name=Queues,proto3" json:"Queues,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func NewPopulatedQueuesInfo added in v1.3.1 

func NewPopulatedQueuesInfo(r randyKubemqGo, easy bool) *QueuesInfo

func (*QueuesInfo) Descriptor added in v1.3.1 

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

func (*QueuesInfo) Equal added in v1.3.1 

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

func (*QueuesInfo) GetDelivered added in v1.3.1 

func (m *QueuesInfo) GetDelivered() int64

func (*QueuesInfo) GetQueues added in v1.3.1 

func (m *QueuesInfo) GetQueues() []*QueueInfo

func (*QueuesInfo) GetSent added in v1.3.1 

func (m *QueuesInfo) GetSent() int64

func (*QueuesInfo) GetTotalQueue added in v1.3.1 

func (m *QueuesInfo) GetTotalQueue() int32

func (*QueuesInfo) GetWaiting added in v1.3.1 

func (m *QueuesInfo) GetWaiting() int64

func (*QueuesInfo) GoString added in v1.3.1 

func (this *QueuesInfo) GoString() string

func (*QueuesInfo) Marshal added in v1.3.1 

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

func (*QueuesInfo) MarshalTo added in v1.3.1 

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

func (*QueuesInfo) ProtoMessage added in v1.3.1 

func (*QueuesInfo) ProtoMessage()

func (*QueuesInfo) Reset added in v1.3.1 

func (m *QueuesInfo) Reset()

func (*QueuesInfo) Size added in v1.3.1 

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

func (*QueuesInfo) String added in v1.3.1 

func (this *QueuesInfo) String() string

func (*QueuesInfo) Unmarshal added in v1.3.1 

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

func (*QueuesInfo) XXX_DiscardUnknown added in v1.3.1 

func (m *QueuesInfo) XXX_DiscardUnknown()

func (*QueuesInfo) XXX_Marshal added in v1.3.1 

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

func (*QueuesInfo) XXX_Merge added in v1.3.1 

func (m *QueuesInfo) XXX_Merge(src proto.Message)

func (*QueuesInfo) XXX_Size added in v1.3.1 

func (m *QueuesInfo) XXX_Size() int

func (*QueuesInfo) XXX_Unmarshal added in v1.3.1 

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

type QueuesInfoRequest added in v1.3.1 

type QueuesInfoRequest struct {
	RequestID            string   `protobuf:"bytes,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	QueueName            string   `protobuf:"bytes,2,opt,name=QueueName,proto3" json:"QueueName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedQueuesInfoRequest added in v1.3.1 

func NewPopulatedQueuesInfoRequest(r randyKubemqGo, easy bool) *QueuesInfoRequest

func (*QueuesInfoRequest) Descriptor added in v1.3.1 

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

func (*QueuesInfoRequest) Equal added in v1.3.1 

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

func (*QueuesInfoRequest) GetQueueName added in v1.3.1 

func (m *QueuesInfoRequest) GetQueueName() string

func (*QueuesInfoRequest) GetRequestID added in v1.3.1 

func (m *QueuesInfoRequest) GetRequestID() string

func (*QueuesInfoRequest) GoString added in v1.3.1 

func (this *QueuesInfoRequest) GoString() string

func (*QueuesInfoRequest) Marshal added in v1.3.1 

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

func (*QueuesInfoRequest) MarshalTo added in v1.3.1 

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

func (*QueuesInfoRequest) ProtoMessage added in v1.3.1 

func (*QueuesInfoRequest) ProtoMessage()

func (*QueuesInfoRequest) Reset added in v1.3.1 

func (m *QueuesInfoRequest) Reset()

func (*QueuesInfoRequest) Size added in v1.3.1 

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

func (*QueuesInfoRequest) String added in v1.3.1 

func (this *QueuesInfoRequest) String() string

func (*QueuesInfoRequest) Unmarshal added in v1.3.1 

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

func (*QueuesInfoRequest) XXX_DiscardUnknown added in v1.3.1 

func (m *QueuesInfoRequest) XXX_DiscardUnknown()

func (*QueuesInfoRequest) XXX_Marshal added in v1.3.1 

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

func (*QueuesInfoRequest) XXX_Merge added in v1.3.1 

func (m *QueuesInfoRequest) XXX_Merge(src proto.Message)

func (*QueuesInfoRequest) XXX_Size added in v1.3.1 

func (m *QueuesInfoRequest) XXX_Size() int

func (*QueuesInfoRequest) XXX_Unmarshal added in v1.3.1 

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

type QueuesInfoResponse added in v1.3.1 

type QueuesInfoResponse struct {
	RefRequestID         string      `protobuf:"bytes,1,opt,name=RefRequestID,proto3" json:"RefRequestID,omitempty"`
	Info                 *QueuesInfo `protobuf:"bytes,2,opt,name=Info,proto3" json:"Info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func NewPopulatedQueuesInfoResponse added in v1.3.1 

func NewPopulatedQueuesInfoResponse(r randyKubemqGo, easy bool) *QueuesInfoResponse

func (*QueuesInfoResponse) Descriptor added in v1.3.1 

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

func (*QueuesInfoResponse) Equal added in v1.3.1 

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

func (*QueuesInfoResponse) GetInfo added in v1.3.1 

func (m *QueuesInfoResponse) GetInfo() *QueuesInfo

func (*QueuesInfoResponse) GetRefRequestID added in v1.3.1 

func (m *QueuesInfoResponse) GetRefRequestID() string

func (*QueuesInfoResponse) GoString added in v1.3.1 

func (this *QueuesInfoResponse) GoString() string

func (*QueuesInfoResponse) Marshal added in v1.3.1 

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

func (*QueuesInfoResponse) MarshalTo added in v1.3.1 

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

func (*QueuesInfoResponse) ProtoMessage added in v1.3.1 

func (*QueuesInfoResponse) ProtoMessage()

func (*QueuesInfoResponse) Reset added in v1.3.1 

func (m *QueuesInfoResponse) Reset()

func (*QueuesInfoResponse) Size added in v1.3.1 

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

func (*QueuesInfoResponse) String added in v1.3.1 

func (this *QueuesInfoResponse) String() string

func (*QueuesInfoResponse) Unmarshal added in v1.3.1 

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

func (*QueuesInfoResponse) XXX_DiscardUnknown added in v1.3.1 

func (m *QueuesInfoResponse) XXX_DiscardUnknown()

func (*QueuesInfoResponse) XXX_Marshal added in v1.3.1 

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

func (*QueuesInfoResponse) XXX_Merge added in v1.3.1 

func (m *QueuesInfoResponse) XXX_Merge(src proto.Message)

func (*QueuesInfoResponse) XXX_Size added in v1.3.1 

func (m *QueuesInfoResponse) XXX_Size() int

func (*QueuesInfoResponse) XXX_Unmarshal added in v1.3.1 

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

type QueuesUpstreamRequest added in v1.3.0 

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

func NewPopulatedQueuesUpstreamRequest added in v1.3.0 

func NewPopulatedQueuesUpstreamRequest(r randyKubemqGo, easy bool) *QueuesUpstreamRequest

func (*QueuesUpstreamRequest) Descriptor added in v1.3.0 

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

func (*QueuesUpstreamRequest) Equal added in v1.3.0 

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

func (*QueuesUpstreamRequest) GetMessages added in v1.3.0 

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

func (*QueuesUpstreamRequest) GetRequestID added in v1.3.0 

func (m *QueuesUpstreamRequest) GetRequestID() string

func (*QueuesUpstreamRequest) GoString added in v1.3.0 

func (this *QueuesUpstreamRequest) GoString() string

func (*QueuesUpstreamRequest) Marshal added in v1.3.0 

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

func (*QueuesUpstreamRequest) MarshalTo added in v1.3.0 

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

func (*QueuesUpstreamRequest) ProtoMessage added in v1.3.0 

func (*QueuesUpstreamRequest) ProtoMessage()

func (*QueuesUpstreamRequest) Reset added in v1.3.0 

func (m *QueuesUpstreamRequest) Reset()

func (*QueuesUpstreamRequest) Size added in v1.3.0 

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

func (*QueuesUpstreamRequest) String added in v1.3.0 

func (this *QueuesUpstreamRequest) String() string

func (*QueuesUpstreamRequest) Unmarshal added in v1.3.0 

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

func (*QueuesUpstreamRequest) XXX_DiscardUnknown added in v1.3.0 

func (m *QueuesUpstreamRequest) XXX_DiscardUnknown()

func (*QueuesUpstreamRequest) XXX_Marshal added in v1.3.0 

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

func (*QueuesUpstreamRequest) XXX_Merge added in v1.3.0 

func (m *QueuesUpstreamRequest) XXX_Merge(src proto.Message)

func (*QueuesUpstreamRequest) XXX_Size added in v1.3.0 

func (m *QueuesUpstreamRequest) XXX_Size() int

func (*QueuesUpstreamRequest) XXX_Unmarshal added in v1.3.0 

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

type QueuesUpstreamResponse added in v1.3.0 

type QueuesUpstreamResponse struct {
	RefRequestID         string                    `protobuf:"bytes,1,opt,name=RefRequestID,proto3" json:"RefRequestID,omitempty"`
	Results              []*SendQueueMessageResult `protobuf:"bytes,2,rep,name=Results,proto3" json:"Results,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_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func NewPopulatedQueuesUpstreamResponse added in v1.3.0 

func NewPopulatedQueuesUpstreamResponse(r randyKubemqGo, easy bool) *QueuesUpstreamResponse

func (*QueuesUpstreamResponse) Descriptor added in v1.3.0 

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

func (*QueuesUpstreamResponse) Equal added in v1.3.0 

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

func (*QueuesUpstreamResponse) GetError added in v1.3.0 

func (m *QueuesUpstreamResponse) GetError() string

func (*QueuesUpstreamResponse) GetIsError added in v1.3.0 

func (m *QueuesUpstreamResponse) GetIsError() bool

func (*QueuesUpstreamResponse) GetRefRequestID added in v1.3.0 

func (m *QueuesUpstreamResponse) GetRefRequestID() string

func (*QueuesUpstreamResponse) GetResults added in v1.3.0 

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

func (*QueuesUpstreamResponse) GoString added in v1.3.0 

func (this *QueuesUpstreamResponse) GoString() string

func (*QueuesUpstreamResponse) Marshal added in v1.3.0 

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

func (*QueuesUpstreamResponse) MarshalTo added in v1.3.0 

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

func (*QueuesUpstreamResponse) ProtoMessage added in v1.3.0 

func (*QueuesUpstreamResponse) ProtoMessage()

func (*QueuesUpstreamResponse) Reset added in v1.3.0 

func (m *QueuesUpstreamResponse) Reset()

func (*QueuesUpstreamResponse) Size added in v1.3.0 

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

func (*QueuesUpstreamResponse) String added in v1.3.0 

func (this *QueuesUpstreamResponse) String() string

func (*QueuesUpstreamResponse) Unmarshal added in v1.3.0 

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

func (*QueuesUpstreamResponse) XXX_DiscardUnknown added in v1.3.0 

func (m *QueuesUpstreamResponse) XXX_DiscardUnknown()

func (*QueuesUpstreamResponse) XXX_Marshal added in v1.3.0 

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

func (*QueuesUpstreamResponse) XXX_Merge added in v1.3.0 

func (m *QueuesUpstreamResponse) XXX_Merge(src proto.Message)

func (*QueuesUpstreamResponse) XXX_Size added in v1.3.0 

func (m *QueuesUpstreamResponse) XXX_Size() int

func (*QueuesUpstreamResponse) XXX_Unmarshal added in v1.3.0 

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

type ReceiveQueueMessagesRequest added in v1.1.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_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedReceiveQueueMessagesRequest added in v1.1.0 

func NewPopulatedReceiveQueueMessagesRequest(r randyKubemqGo, easy bool) *ReceiveQueueMessagesRequest

func (*ReceiveQueueMessagesRequest) Descriptor added in v1.1.0 

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

func (*ReceiveQueueMessagesRequest) Equal added in v1.1.0 

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

func (*ReceiveQueueMessagesRequest) GetChannel added in v1.1.0 

func (m *ReceiveQueueMessagesRequest) GetChannel() string

func (*ReceiveQueueMessagesRequest) GetClientID added in v1.1.0 

func (m *ReceiveQueueMessagesRequest) GetClientID() string

func (*ReceiveQueueMessagesRequest) GetIsPeak added in v1.1.0 

func (m *ReceiveQueueMessagesRequest) GetIsPeak() bool

func (*ReceiveQueueMessagesRequest) GetMaxNumberOfMessages added in v1.1.0 

func (m *ReceiveQueueMessagesRequest) GetMaxNumberOfMessages() int32

func (*ReceiveQueueMessagesRequest) GetRequestID added in v1.1.0 

func (m *ReceiveQueueMessagesRequest) GetRequestID() string

func (*ReceiveQueueMessagesRequest) GetWaitTimeSeconds added in v1.1.0 

func (m *ReceiveQueueMessagesRequest) GetWaitTimeSeconds() int32

func (*ReceiveQueueMessagesRequest) GoString added in v1.1.0 

func (this *ReceiveQueueMessagesRequest) GoString() string

func (*ReceiveQueueMessagesRequest) Marshal added in v1.1.0 

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

func (*ReceiveQueueMessagesRequest) MarshalTo added in v1.1.0 

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

func (*ReceiveQueueMessagesRequest) ProtoMessage added in v1.1.0 

func (*ReceiveQueueMessagesRequest) ProtoMessage()

func (*ReceiveQueueMessagesRequest) Reset added in v1.1.0 

func (m *ReceiveQueueMessagesRequest) Reset()

func (*ReceiveQueueMessagesRequest) Size added in v1.1.0 

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

func (*ReceiveQueueMessagesRequest) String added in v1.1.0 

func (this *ReceiveQueueMessagesRequest) String() string

func (*ReceiveQueueMessagesRequest) Unmarshal added in v1.1.0 

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

func (*ReceiveQueueMessagesRequest) XXX_DiscardUnknown added in v1.1.0 

func (m *ReceiveQueueMessagesRequest) XXX_DiscardUnknown()

func (*ReceiveQueueMessagesRequest) XXX_Marshal added in v1.1.0 

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

func (*ReceiveQueueMessagesRequest) XXX_Merge added in v1.1.0 

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

func (*ReceiveQueueMessagesRequest) XXX_Size added in v1.1.0 

func (m *ReceiveQueueMessagesRequest) XXX_Size() int

func (*ReceiveQueueMessagesRequest) XXX_Unmarshal added in v1.1.0 

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

type ReceiveQueueMessagesResponse added in v1.1.0 

type ReceiveQueueMessagesResponse struct {
	RequestID            string          `protobuf:"bytes,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	Messages             []*QueueMessage `protobuf:"bytes,2,rep,name=Messages,proto3" 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_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func NewPopulatedReceiveQueueMessagesResponse added in v1.1.0 

func NewPopulatedReceiveQueueMessagesResponse(r randyKubemqGo, easy bool) *ReceiveQueueMessagesResponse

func (*ReceiveQueueMessagesResponse) Descriptor added in v1.1.0 

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

func (*ReceiveQueueMessagesResponse) Equal added in v1.1.0 

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

func (*ReceiveQueueMessagesResponse) GetError added in v1.1.0 

func (m *ReceiveQueueMessagesResponse) GetError() string

func (*ReceiveQueueMessagesResponse) GetIsError added in v1.1.0 

func (m *ReceiveQueueMessagesResponse) GetIsError() bool

func (*ReceiveQueueMessagesResponse) GetIsPeak added in v1.1.0 

func (m *ReceiveQueueMessagesResponse) GetIsPeak() bool

func (*ReceiveQueueMessagesResponse) GetMessages added in v1.1.0 

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

func (*ReceiveQueueMessagesResponse) GetMessagesExpired added in v1.1.0 

func (m *ReceiveQueueMessagesResponse) GetMessagesExpired() int32

func (*ReceiveQueueMessagesResponse) GetMessagesReceived added in v1.1.0 

func (m *ReceiveQueueMessagesResponse) GetMessagesReceived() int32

func (*ReceiveQueueMessagesResponse) GetRequestID added in v1.1.0 

func (m *ReceiveQueueMessagesResponse) GetRequestID() string

func (*ReceiveQueueMessagesResponse) GoString added in v1.1.0 

func (this *ReceiveQueueMessagesResponse) GoString() string

func (*ReceiveQueueMessagesResponse) Marshal added in v1.1.0 

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

func (*ReceiveQueueMessagesResponse) MarshalTo added in v1.1.0 

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

func (*ReceiveQueueMessagesResponse) ProtoMessage added in v1.1.0 

func (*ReceiveQueueMessagesResponse) ProtoMessage()

func (*ReceiveQueueMessagesResponse) Reset added in v1.1.0 

func (m *ReceiveQueueMessagesResponse) Reset()

func (*ReceiveQueueMessagesResponse) Size added in v1.1.0 

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

func (*ReceiveQueueMessagesResponse) String added in v1.1.0 

func (this *ReceiveQueueMessagesResponse) String() string

func (*ReceiveQueueMessagesResponse) Unmarshal added in v1.1.0 

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

func (*ReceiveQueueMessagesResponse) XXX_DiscardUnknown added in v1.1.0 

func (m *ReceiveQueueMessagesResponse) XXX_DiscardUnknown()

func (*ReceiveQueueMessagesResponse) XXX_Marshal added in v1.1.0 

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

func (*ReceiveQueueMessagesResponse) XXX_Merge added in v1.1.0 

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

func (*ReceiveQueueMessagesResponse) XXX_Size added in v1.1.0 

func (m *ReceiveQueueMessagesResponse) XXX_Size() int

func (*ReceiveQueueMessagesResponse) XXX_Unmarshal added in v1.1.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   `` /* 150-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `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 added in v1.1.0 

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

func (*Request) GetTags added in v1.1.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 (m *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 (
	Request_RequestTypeUnknown Request_RequestType = 0
	Request_Command            Request_RequestType = 1
	Request_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 `` /* 150-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `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 added in v1.1.0 

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

func (*Response) GetTags added in v1.1.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 (m *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_unrecognized     []byte   `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 (m *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 SendPartitionResults added in v1.3.1 

type SendPartitionResults struct {
	PartitionResults     []*SendQueueMessageResult `protobuf:"bytes,1,rep,name=PartitionResults,proto3" json:"PartitionResults,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func NewPopulatedSendPartitionResults added in v1.3.1 

func NewPopulatedSendPartitionResults(r randyKubemqGo, easy bool) *SendPartitionResults

func (*SendPartitionResults) Descriptor added in v1.3.1 

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

func (*SendPartitionResults) Equal added in v1.3.1 

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

func (*SendPartitionResults) GetPartitionResults added in v1.3.1 

func (m *SendPartitionResults) GetPartitionResults() []*SendQueueMessageResult

func (*SendPartitionResults) GoString added in v1.3.1 

func (this *SendPartitionResults) GoString() string

func (*SendPartitionResults) Marshal added in v1.3.1 

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

func (*SendPartitionResults) MarshalTo added in v1.3.1 

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

func (*SendPartitionResults) ProtoMessage added in v1.3.1 

func (*SendPartitionResults) ProtoMessage()

func (*SendPartitionResults) Reset added in v1.3.1 

func (m *SendPartitionResults) Reset()

func (*SendPartitionResults) Size added in v1.3.1 

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

func (*SendPartitionResults) String added in v1.3.1 

func (this *SendPartitionResults) String() string

func (*SendPartitionResults) Unmarshal added in v1.3.1 

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

func (*SendPartitionResults) XXX_DiscardUnknown added in v1.3.1 

func (m *SendPartitionResults) XXX_DiscardUnknown()

func (*SendPartitionResults) XXX_Marshal added in v1.3.1 

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

func (*SendPartitionResults) XXX_Merge added in v1.3.1 

func (m *SendPartitionResults) XXX_Merge(src proto.Message)

func (*SendPartitionResults) XXX_Size added in v1.3.1 

func (m *SendPartitionResults) XXX_Size() int

func (*SendPartitionResults) XXX_Unmarshal added in v1.3.1 

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

type SendQueueMessageResult added in v1.1.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"`
	RefChannel           string   `protobuf:"bytes,7,opt,name=RefChannel,proto3" json:"RefChannel,omitempty"`
	RefTopic             string   `protobuf:"bytes,8,opt,name=RefTopic,proto3" json:"RefTopic,omitempty"`
	RefPartition         int32    `protobuf:"varint,9,opt,name=RefPartition,proto3" json:"RefPartition,omitempty"`
	RefHash              string   `protobuf:"bytes,10,opt,name=RefHash,proto3" json:"RefHash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedSendQueueMessageResult added in v1.1.0 

func NewPopulatedSendQueueMessageResult(r randyKubemqGo, easy bool) *SendQueueMessageResult

func (*SendQueueMessageResult) Descriptor added in v1.1.0 

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

func (*SendQueueMessageResult) Equal added in v1.1.0 

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

func (*SendQueueMessageResult) GetDelayedTo added in v1.1.0 

func (m *SendQueueMessageResult) GetDelayedTo() int64

func (*SendQueueMessageResult) GetError added in v1.1.0 

func (m *SendQueueMessageResult) GetError() string

func (*SendQueueMessageResult) GetExpirationAt added in v1.1.0 

func (m *SendQueueMessageResult) GetExpirationAt() int64

func (*SendQueueMessageResult) GetIsError added in v1.1.0 

func (m *SendQueueMessageResult) GetIsError() bool

func (*SendQueueMessageResult) GetMessageID added in v1.1.0 

func (m *SendQueueMessageResult) GetMessageID() string

func (*SendQueueMessageResult) GetRefChannel added in v1.3.1 

func (m *SendQueueMessageResult) GetRefChannel() string

func (*SendQueueMessageResult) GetRefHash added in v1.3.1 

func (m *SendQueueMessageResult) GetRefHash() string

func (*SendQueueMessageResult) GetRefPartition added in v1.3.1 

func (m *SendQueueMessageResult) GetRefPartition() int32

func (*SendQueueMessageResult) GetRefTopic added in v1.3.1 

func (m *SendQueueMessageResult) GetRefTopic() string

func (*SendQueueMessageResult) GetSentAt added in v1.1.0 

func (m *SendQueueMessageResult) GetSentAt() int64

func (*SendQueueMessageResult) GoString added in v1.1.0 

func (this *SendQueueMessageResult) GoString() string

func (*SendQueueMessageResult) Marshal added in v1.1.0 

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

func (*SendQueueMessageResult) MarshalTo added in v1.1.0 

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

func (*SendQueueMessageResult) ProtoMessage added in v1.1.0 

func (*SendQueueMessageResult) ProtoMessage()

func (*SendQueueMessageResult) Reset added in v1.1.0 

func (m *SendQueueMessageResult) Reset()

func (*SendQueueMessageResult) Size added in v1.1.0 

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

func (*SendQueueMessageResult) String added in v1.1.0 

func (this *SendQueueMessageResult) String() string

func (*SendQueueMessageResult) Unmarshal added in v1.1.0 

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

func (*SendQueueMessageResult) XXX_DiscardUnknown added in v1.1.0 

func (m *SendQueueMessageResult) XXX_DiscardUnknown()

func (*SendQueueMessageResult) XXX_Marshal added in v1.1.0 

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

func (*SendQueueMessageResult) XXX_Merge added in v1.1.0 

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

func (*SendQueueMessageResult) XXX_Size added in v1.1.0 

func (m *SendQueueMessageResult) XXX_Size() int

func (*SendQueueMessageResult) XXX_Unmarshal added in v1.1.0 

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

type SendTopicResults added in v1.3.1 

type SendTopicResults struct {
	TopicResults         map[int32]*SendPartitionResults `` /* 166-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func NewPopulatedSendTopicResults added in v1.3.1 

func NewPopulatedSendTopicResults(r randyKubemqGo, easy bool) *SendTopicResults

func (*SendTopicResults) Descriptor added in v1.3.1 

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

func (*SendTopicResults) Equal added in v1.3.1 

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

func (*SendTopicResults) GetTopicResults added in v1.3.1 

func (m *SendTopicResults) GetTopicResults() map[int32]*SendPartitionResults

func (*SendTopicResults) GoString added in v1.3.1 

func (this *SendTopicResults) GoString() string

func (*SendTopicResults) Marshal added in v1.3.1 

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

func (*SendTopicResults) MarshalTo added in v1.3.1 

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

func (*SendTopicResults) ProtoMessage added in v1.3.1 

func (*SendTopicResults) ProtoMessage()

func (*SendTopicResults) Reset added in v1.3.1 

func (m *SendTopicResults) Reset()

func (*SendTopicResults) Size added in v1.3.1 

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

func (*SendTopicResults) String added in v1.3.1 

func (this *SendTopicResults) String() string

func (*SendTopicResults) Unmarshal added in v1.3.1 

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

func (*SendTopicResults) XXX_DiscardUnknown added in v1.3.1 

func (m *SendTopicResults) XXX_DiscardUnknown()

func (*SendTopicResults) XXX_Marshal added in v1.3.1 

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

func (*SendTopicResults) XXX_Merge added in v1.3.1 

func (m *SendTopicResults) XXX_Merge(src proto.Message)

func (*SendTopicResults) XXX_Size added in v1.3.1 

func (m *SendTopicResults) XXX_Size() int

func (*SendTopicResults) XXX_Unmarshal added in v1.3.1 

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

type StreamQueueMessagesRequest added in v1.1.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,proto3" json:"ModifiedMessage,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}          `json:"-"`
	XXX_unrecognized      []byte            `json:"-"`
	XXX_sizecache         int32             `json:"-"`
}

func NewPopulatedStreamQueueMessagesRequest added in v1.1.0 

func NewPopulatedStreamQueueMessagesRequest(r randyKubemqGo, easy bool) *StreamQueueMessagesRequest

func (*StreamQueueMessagesRequest) Descriptor added in v1.1.0 

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

func (*StreamQueueMessagesRequest) Equal added in v1.1.0 

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

func (*StreamQueueMessagesRequest) GetChannel added in v1.1.0 

func (m *StreamQueueMessagesRequest) GetChannel() string

func (*StreamQueueMessagesRequest) GetClientID added in v1.1.0 

func (m *StreamQueueMessagesRequest) GetClientID() string

func (*StreamQueueMessagesRequest) GetModifiedMessage added in v1.1.0 

func (m *StreamQueueMessagesRequest) GetModifiedMessage() *QueueMessage

func (*StreamQueueMessagesRequest) GetRefSequence added in v1.1.0 

func (m *StreamQueueMessagesRequest) GetRefSequence() uint64

func (*StreamQueueMessagesRequest) GetRequestID added in v1.1.0 

func (m *StreamQueueMessagesRequest) GetRequestID() string

func (*StreamQueueMessagesRequest) GetStreamRequestTypeData added in v1.1.0 

func (m *StreamQueueMessagesRequest) GetStreamRequestTypeData() StreamRequestType

func (*StreamQueueMessagesRequest) GetVisibilitySeconds added in v1.1.0 

func (m *StreamQueueMessagesRequest) GetVisibilitySeconds() int32

func (*StreamQueueMessagesRequest) GetWaitTimeSeconds added in v1.1.0 

func (m *StreamQueueMessagesRequest) GetWaitTimeSeconds() int32

func (*StreamQueueMessagesRequest) GoString added in v1.1.0 

func (this *StreamQueueMessagesRequest) GoString() string

func (*StreamQueueMessagesRequest) Marshal added in v1.1.0 

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

func (*StreamQueueMessagesRequest) MarshalTo added in v1.1.0 

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

func (*StreamQueueMessagesRequest) ProtoMessage added in v1.1.0 

func (*StreamQueueMessagesRequest) ProtoMessage()

func (*StreamQueueMessagesRequest) Reset added in v1.1.0 

func (m *StreamQueueMessagesRequest) Reset()

func (*StreamQueueMessagesRequest) Size added in v1.1.0 

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

func (*StreamQueueMessagesRequest) String added in v1.1.0 

func (this *StreamQueueMessagesRequest) String() string

func (*StreamQueueMessagesRequest) Unmarshal added in v1.1.0 

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

func (*StreamQueueMessagesRequest) XXX_DiscardUnknown added in v1.1.0 

func (m *StreamQueueMessagesRequest) XXX_DiscardUnknown()

func (*StreamQueueMessagesRequest) XXX_Marshal added in v1.1.0 

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

func (*StreamQueueMessagesRequest) XXX_Merge added in v1.1.0 

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

func (*StreamQueueMessagesRequest) XXX_Size added in v1.1.0 

func (m *StreamQueueMessagesRequest) XXX_Size() int

func (*StreamQueueMessagesRequest) XXX_Unmarshal added in v1.1.0 

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

type StreamQueueMessagesResponse added in v1.1.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,proto3" 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_unrecognized      []byte            `json:"-"`
	XXX_sizecache         int32             `json:"-"`
}

func NewPopulatedStreamQueueMessagesResponse added in v1.1.0 

func NewPopulatedStreamQueueMessagesResponse(r randyKubemqGo, easy bool) *StreamQueueMessagesResponse

func (*StreamQueueMessagesResponse) Descriptor added in v1.1.0 

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

func (*StreamQueueMessagesResponse) Equal added in v1.1.0 

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

func (*StreamQueueMessagesResponse) GetError added in v1.1.0 

func (m *StreamQueueMessagesResponse) GetError() string

func (*StreamQueueMessagesResponse) GetIsError added in v1.1.0 

func (m *StreamQueueMessagesResponse) GetIsError() bool

func (*StreamQueueMessagesResponse) GetMessage added in v1.1.0 

func (m *StreamQueueMessagesResponse) GetMessage() *QueueMessage

func (*StreamQueueMessagesResponse) GetRequestID added in v1.1.0 

func (m *StreamQueueMessagesResponse) GetRequestID() string

func (*StreamQueueMessagesResponse) GetStreamRequestTypeData added in v1.1.0 

func (m *StreamQueueMessagesResponse) GetStreamRequestTypeData() StreamRequestType

func (*StreamQueueMessagesResponse) GoString added in v1.1.0 

func (this *StreamQueueMessagesResponse) GoString() string

func (*StreamQueueMessagesResponse) Marshal added in v1.1.0 

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

func (*StreamQueueMessagesResponse) MarshalTo added in v1.1.0 

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

func (*StreamQueueMessagesResponse) ProtoMessage added in v1.1.0 

func (*StreamQueueMessagesResponse) ProtoMessage()

func (*StreamQueueMessagesResponse) Reset added in v1.1.0 

func (m *StreamQueueMessagesResponse) Reset()

func (*StreamQueueMessagesResponse) Size added in v1.1.0 

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

func (*StreamQueueMessagesResponse) String added in v1.1.0 

func (this *StreamQueueMessagesResponse) String() string

func (*StreamQueueMessagesResponse) Unmarshal added in v1.1.0 

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

func (*StreamQueueMessagesResponse) XXX_DiscardUnknown added in v1.1.0 

func (m *StreamQueueMessagesResponse) XXX_DiscardUnknown()

func (*StreamQueueMessagesResponse) XXX_Marshal added in v1.1.0 

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

func (*StreamQueueMessagesResponse) XXX_Merge added in v1.1.0 

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

func (*StreamQueueMessagesResponse) XXX_Size added in v1.1.0 

func (m *StreamQueueMessagesResponse) XXX_Size() int

func (*StreamQueueMessagesResponse) XXX_Unmarshal added in v1.1.0 

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

type StreamRequestType added in v1.1.0 

type StreamRequestType int32
const (
	StreamRequestType_StreamRequestTypeUnknown StreamRequestType = 0
	StreamRequestType_ReceiveMessage           StreamRequestType = 1
	StreamRequestType_AckMessage               StreamRequestType = 2
	StreamRequestType_RejectMessage            StreamRequestType = 3
	StreamRequestType_ModifyVisibility         StreamRequestType = 4
	StreamRequestType_ResendMessage            StreamRequestType = 5
	StreamRequestType_SendModifiedMessage      StreamRequestType = 6
)

func (StreamRequestType) EnumDescriptor added in v1.1.0 

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

func (StreamRequestType) String added in v1.1.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_unrecognized     []byte                    `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 (m *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 (
	Subscribe_EventsStoreTypeUndefined Subscribe_EventsStoreType = 0
	Subscribe_StartNewOnly             Subscribe_EventsStoreType = 1
	Subscribe_StartFromFirst           Subscribe_EventsStoreType = 2
	Subscribe_StartFromLast            Subscribe_EventsStoreType = 3
	Subscribe_StartAtSequence          Subscribe_EventsStoreType = 4
	Subscribe_StartAtTime              Subscribe_EventsStoreType = 5
	Subscribe_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 (
	Subscribe_SubscribeTypeUndefined Subscribe_SubscribeType = 0
	Subscribe_Events                 Subscribe_SubscribeType = 1
	Subscribe_EventsStore            Subscribe_SubscribeType = 2
	Subscribe_Commands               Subscribe_SubscribeType = 3
	Subscribe_Queries                Subscribe_SubscribeType = 4
)

func (Subscribe_SubscribeType) EnumDescriptor 

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

func (Subscribe_SubscribeType) String 

func (x Subscribe_SubscribeType) String() string

type TopicPartition added in v1.3.1 

type TopicPartition struct {
	Topic                string   `protobuf:"bytes,1,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Partition            uint32   `protobuf:"varint,2,opt,name=Partition,proto3" json:"Partition,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedTopicPartition added in v1.3.1 

func NewPopulatedTopicPartition(r randyKubemqGo, easy bool) *TopicPartition

func (*TopicPartition) Descriptor added in v1.3.1 

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

func (*TopicPartition) Equal added in v1.3.1 

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

func (*TopicPartition) GetPartition added in v1.3.1 

func (m *TopicPartition) GetPartition() uint32

func (*TopicPartition) GetTopic added in v1.3.1 

func (m *TopicPartition) GetTopic() string

func (*TopicPartition) GoString added in v1.3.1 

func (this *TopicPartition) GoString() string

func (*TopicPartition) Marshal added in v1.3.1 

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

func (*TopicPartition) MarshalTo added in v1.3.1 

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

func (*TopicPartition) ProtoMessage added in v1.3.1 

func (*TopicPartition) ProtoMessage()

func (*TopicPartition) Reset added in v1.3.1 

func (m *TopicPartition) Reset()

func (*TopicPartition) Size added in v1.3.1 

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

func (*TopicPartition) String added in v1.3.1 

func (this *TopicPartition) String() string

func (*TopicPartition) Unmarshal added in v1.3.1 

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

func (*TopicPartition) XXX_DiscardUnknown added in v1.3.1 

func (m *TopicPartition) XXX_DiscardUnknown()

func (*TopicPartition) XXX_Marshal added in v1.3.1 

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

func (*TopicPartition) XXX_Merge added in v1.3.1 

func (m *TopicPartition) XXX_Merge(src proto.Message)

func (*TopicPartition) XXX_Size added in v1.3.1 

func (m *TopicPartition) XXX_Size() int

func (*TopicPartition) XXX_Unmarshal added in v1.3.1 

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

type TopicRecord added in v1.3.1 

type TopicRecord struct {
	Headers              []*TopicRecordHeader `protobuf:"bytes,1,rep,name=Headers,proto3" json:"Headers,omitempty"`
	Topic                string               `protobuf:"bytes,2,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Partition            uint32               `protobuf:"varint,3,opt,name=Partition,proto3" json:"Partition,omitempty"`
	Timestamp            uint64               `protobuf:"varint,4,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Key                  []byte               `protobuf:"bytes,5,opt,name=Key,proto3" json:"Key,omitempty"`
	Value                []byte               `protobuf:"bytes,6,opt,name=Value,proto3" json:"Value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func NewPopulatedTopicRecord added in v1.3.1 

func NewPopulatedTopicRecord(r randyKubemqGo, easy bool) *TopicRecord

func (*TopicRecord) Descriptor added in v1.3.1 

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

func (*TopicRecord) Equal added in v1.3.1 

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

func (*TopicRecord) GetHeaders added in v1.3.1 

func (m *TopicRecord) GetHeaders() []*TopicRecordHeader

func (*TopicRecord) GetKey added in v1.3.1 

func (m *TopicRecord) GetKey() []byte

func (*TopicRecord) GetPartition added in v1.3.1 

func (m *TopicRecord) GetPartition() uint32

func (*TopicRecord) GetTimestamp added in v1.3.1 

func (m *TopicRecord) GetTimestamp() uint64

func (*TopicRecord) GetTopic added in v1.3.1 

func (m *TopicRecord) GetTopic() string

func (*TopicRecord) GetValue added in v1.3.1 

func (m *TopicRecord) GetValue() []byte

func (*TopicRecord) GoString added in v1.3.1 

func (this *TopicRecord) GoString() string

func (*TopicRecord) Marshal added in v1.3.1 

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

func (*TopicRecord) MarshalTo added in v1.3.1 

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

func (*TopicRecord) ProtoMessage added in v1.3.1 

func (*TopicRecord) ProtoMessage()

func (*TopicRecord) Reset added in v1.3.1 

func (m *TopicRecord) Reset()

func (*TopicRecord) Size added in v1.3.1 

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

func (*TopicRecord) String added in v1.3.1 

func (this *TopicRecord) String() string

func (*TopicRecord) Unmarshal added in v1.3.1 

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

func (*TopicRecord) XXX_DiscardUnknown added in v1.3.1 

func (m *TopicRecord) XXX_DiscardUnknown()

func (*TopicRecord) XXX_Marshal added in v1.3.1 

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

func (*TopicRecord) XXX_Merge added in v1.3.1 

func (m *TopicRecord) XXX_Merge(src proto.Message)

func (*TopicRecord) XXX_Size added in v1.3.1 

func (m *TopicRecord) XXX_Size() int

func (*TopicRecord) XXX_Unmarshal added in v1.3.1 

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

type TopicRecordHeader added in v1.3.1 

type TopicRecordHeader struct {
	Key                  string   `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedTopicRecordHeader added in v1.3.1 

func NewPopulatedTopicRecordHeader(r randyKubemqGo, easy bool) *TopicRecordHeader

func (*TopicRecordHeader) Descriptor added in v1.3.1 

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

func (*TopicRecordHeader) Equal added in v1.3.1 

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

func (*TopicRecordHeader) GetKey added in v1.3.1 

func (m *TopicRecordHeader) GetKey() string

func (*TopicRecordHeader) GetValue added in v1.3.1 

func (m *TopicRecordHeader) GetValue() []byte

func (*TopicRecordHeader) GoString added in v1.3.1 

func (this *TopicRecordHeader) GoString() string

func (*TopicRecordHeader) Marshal added in v1.3.1 

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

func (*TopicRecordHeader) MarshalTo added in v1.3.1 

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

func (*TopicRecordHeader) ProtoMessage added in v1.3.1 

func (*TopicRecordHeader) ProtoMessage()

func (*TopicRecordHeader) Reset added in v1.3.1 

func (m *TopicRecordHeader) Reset()

func (*TopicRecordHeader) Size added in v1.3.1 

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

func (*TopicRecordHeader) String added in v1.3.1 

func (this *TopicRecordHeader) String() string

func (*TopicRecordHeader) Unmarshal added in v1.3.1 

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

func (*TopicRecordHeader) XXX_DiscardUnknown added in v1.3.1 

func (m *TopicRecordHeader) XXX_DiscardUnknown()

func (*TopicRecordHeader) XXX_Marshal added in v1.3.1 

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

func (*TopicRecordHeader) XXX_Merge added in v1.3.1 

func (m *TopicRecordHeader) XXX_Merge(src proto.Message)

func (*TopicRecordHeader) XXX_Size added in v1.3.1 

func (m *TopicRecordHeader) XXX_Size() int

func (*TopicRecordHeader) XXX_Unmarshal added in v1.3.1 

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

type TopicsDownstreamRequest added in v1.3.1 

type TopicsDownstreamRequest struct {
	RequestID             string                      `protobuf:"bytes,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	DownstreamRequestType TopicsDownstreamRequestType `` /* 136-byte string literal not displayed */
	Data                  []byte                      `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}                    `json:"-"`
	XXX_unrecognized      []byte                      `json:"-"`
	XXX_sizecache         int32                       `json:"-"`
}

func NewPopulatedTopicsDownstreamRequest added in v1.3.1 

func NewPopulatedTopicsDownstreamRequest(r randyKubemqGo, easy bool) *TopicsDownstreamRequest

func (*TopicsDownstreamRequest) Descriptor added in v1.3.1 

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

func (*TopicsDownstreamRequest) Equal added in v1.3.1 

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

func (*TopicsDownstreamRequest) GetData added in v1.3.1 

func (m *TopicsDownstreamRequest) GetData() []byte

func (*TopicsDownstreamRequest) GetDownstreamRequestType added in v1.3.1 

func (m *TopicsDownstreamRequest) GetDownstreamRequestType() TopicsDownstreamRequestType

func (*TopicsDownstreamRequest) GetRequestID added in v1.3.1 

func (m *TopicsDownstreamRequest) GetRequestID() string

func (*TopicsDownstreamRequest) GoString added in v1.3.1 

func (this *TopicsDownstreamRequest) GoString() string

func (*TopicsDownstreamRequest) Marshal added in v1.3.1 

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

func (*TopicsDownstreamRequest) MarshalTo added in v1.3.1 

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

func (*TopicsDownstreamRequest) ProtoMessage added in v1.3.1 

func (*TopicsDownstreamRequest) ProtoMessage()

func (*TopicsDownstreamRequest) Reset added in v1.3.1 

func (m *TopicsDownstreamRequest) Reset()

func (*TopicsDownstreamRequest) Size added in v1.3.1 

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

func (*TopicsDownstreamRequest) String added in v1.3.1 

func (this *TopicsDownstreamRequest) String() string

func (*TopicsDownstreamRequest) Unmarshal added in v1.3.1 

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

func (*TopicsDownstreamRequest) XXX_DiscardUnknown added in v1.3.1 

func (m *TopicsDownstreamRequest) XXX_DiscardUnknown()

func (*TopicsDownstreamRequest) XXX_Marshal added in v1.3.1 

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

func (*TopicsDownstreamRequest) XXX_Merge added in v1.3.1 

func (m *TopicsDownstreamRequest) XXX_Merge(src proto.Message)

func (*TopicsDownstreamRequest) XXX_Size added in v1.3.1 

func (m *TopicsDownstreamRequest) XXX_Size() int

func (*TopicsDownstreamRequest) XXX_Unmarshal added in v1.3.1 

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

type TopicsDownstreamRequestType added in v1.3.1 

type TopicsDownstreamRequestType int32
const (
	TopicsDownstreamRequestType_DownstreamRequestTypeUndefined           TopicsDownstreamRequestType = 0
	TopicsDownstreamRequestType_DownstreamRequestTypeSubscriptionRequest TopicsDownstreamRequestType = 1
	TopicsDownstreamRequestType_DownstreamRequestTypeSubscriptionEvent   TopicsDownstreamRequestType = 2
)

func (TopicsDownstreamRequestType) EnumDescriptor added in v1.3.1 

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

func (TopicsDownstreamRequestType) String added in v1.3.1 

func (x TopicsDownstreamRequestType) String() string

type TopicsDownstreamResponse added in v1.3.1 

type TopicsDownstreamResponse struct {
	TransactionID        string   `protobuf:"bytes,1,opt,name=TransactionID,proto3" json:"TransactionID,omitempty"`
	RefRequestID         string   `protobuf:"bytes,2,opt,name=RefRequestID,proto3" json:"RefRequestID,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	IsError              bool     `protobuf:"varint,15,opt,name=IsError,proto3" json:"IsError,omitempty"`
	Error                string   `protobuf:"bytes,16,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedTopicsDownstreamResponse added in v1.3.1 

func NewPopulatedTopicsDownstreamResponse(r randyKubemqGo, easy bool) *TopicsDownstreamResponse

func (*TopicsDownstreamResponse) Descriptor added in v1.3.1 

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

func (*TopicsDownstreamResponse) Equal added in v1.3.1 

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

func (*TopicsDownstreamResponse) GetData added in v1.3.1 

func (m *TopicsDownstreamResponse) GetData() []byte

func (*TopicsDownstreamResponse) GetError added in v1.3.1 

func (m *TopicsDownstreamResponse) GetError() string

func (*TopicsDownstreamResponse) GetIsError added in v1.3.1 

func (m *TopicsDownstreamResponse) GetIsError() bool

func (*TopicsDownstreamResponse) GetRefRequestID added in v1.3.1 

func (m *TopicsDownstreamResponse) GetRefRequestID() string

func (*TopicsDownstreamResponse) GetTransactionID added in v1.3.1 

func (m *TopicsDownstreamResponse) GetTransactionID() string

func (*TopicsDownstreamResponse) GoString added in v1.3.1 

func (this *TopicsDownstreamResponse) GoString() string

func (*TopicsDownstreamResponse) Marshal added in v1.3.1 

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

func (*TopicsDownstreamResponse) MarshalTo added in v1.3.1 

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

func (*TopicsDownstreamResponse) ProtoMessage added in v1.3.1 

func (*TopicsDownstreamResponse) ProtoMessage()

func (*TopicsDownstreamResponse) Reset added in v1.3.1 

func (m *TopicsDownstreamResponse) Reset()

func (*TopicsDownstreamResponse) Size added in v1.3.1 

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

func (*TopicsDownstreamResponse) String added in v1.3.1 

func (this *TopicsDownstreamResponse) String() string

func (*TopicsDownstreamResponse) Unmarshal added in v1.3.1 

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

func (*TopicsDownstreamResponse) XXX_DiscardUnknown added in v1.3.1 

func (m *TopicsDownstreamResponse) XXX_DiscardUnknown()

func (*TopicsDownstreamResponse) XXX_Marshal added in v1.3.1 

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

func (*TopicsDownstreamResponse) XXX_Merge added in v1.3.1 

func (m *TopicsDownstreamResponse) XXX_Merge(src proto.Message)

func (*TopicsDownstreamResponse) XXX_Size added in v1.3.1 

func (m *TopicsDownstreamResponse) XXX_Size() int

func (*TopicsDownstreamResponse) XXX_Unmarshal added in v1.3.1 

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

type TopicsSubscriptionEvent added in v1.3.1 

type TopicsSubscriptionEvent struct {
	SubscriptionID        string                      `protobuf:"bytes,1,opt,name=SubscriptionID,proto3" json:"SubscriptionID,omitempty"`
	SubscriptionEventType TopicsSubscriptionEventType `` /* 136-byte string literal not displayed */
	GroupID               string                      `protobuf:"bytes,3,opt,name=GroupID,proto3" json:"GroupID,omitempty"`
	MemberID              string                      `protobuf:"bytes,4,opt,name=MemberID,proto3" json:"MemberID,omitempty"`
	Assigned              []*TopicPartition           `protobuf:"bytes,5,rep,name=Assigned,proto3" json:"Assigned,omitempty"`
	ReSyncAt              int64                       `protobuf:"varint,6,opt,name=ReSyncAt,proto3" json:"ReSyncAt,omitempty"`
	IsError               bool                        `protobuf:"varint,15,opt,name=IsError,proto3" json:"IsError,omitempty"`
	Error                 string                      `protobuf:"bytes,16,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}                    `json:"-"`
	XXX_unrecognized      []byte                      `json:"-"`
	XXX_sizecache         int32                       `json:"-"`
}

func NewPopulatedTopicsSubscriptionEvent added in v1.3.1 

func NewPopulatedTopicsSubscriptionEvent(r randyKubemqGo, easy bool) *TopicsSubscriptionEvent

func (*TopicsSubscriptionEvent) Descriptor added in v1.3.1 

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

func (*TopicsSubscriptionEvent) Equal added in v1.3.1 

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

func (*TopicsSubscriptionEvent) GetAssigned added in v1.3.1 

func (m *TopicsSubscriptionEvent) GetAssigned() []*TopicPartition

func (*TopicsSubscriptionEvent) GetError added in v1.3.1 

func (m *TopicsSubscriptionEvent) GetError() string

func (*TopicsSubscriptionEvent) GetGroupID added in v1.3.1 

func (m *TopicsSubscriptionEvent) GetGroupID() string

func (*TopicsSubscriptionEvent) GetIsError added in v1.3.1 

func (m *TopicsSubscriptionEvent) GetIsError() bool

func (*TopicsSubscriptionEvent) GetMemberID added in v1.3.1 

func (m *TopicsSubscriptionEvent) GetMemberID() string

func (*TopicsSubscriptionEvent) GetReSyncAt added in v1.3.1 

func (m *TopicsSubscriptionEvent) GetReSyncAt() int64

func (*TopicsSubscriptionEvent) GetSubscriptionEventType added in v1.3.1 

func (m *TopicsSubscriptionEvent) GetSubscriptionEventType() TopicsSubscriptionEventType

func (*TopicsSubscriptionEvent) GetSubscriptionID added in v1.3.1 

func (m *TopicsSubscriptionEvent) GetSubscriptionID() string

func (*TopicsSubscriptionEvent) GoString added in v1.3.1 

func (this *TopicsSubscriptionEvent) GoString() string

func (*TopicsSubscriptionEvent) Marshal added in v1.3.1 

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

func (*TopicsSubscriptionEvent) MarshalTo added in v1.3.1 

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

func (*TopicsSubscriptionEvent) ProtoMessage added in v1.3.1 

func (*TopicsSubscriptionEvent) ProtoMessage()

func (*TopicsSubscriptionEvent) Reset added in v1.3.1 

func (m *TopicsSubscriptionEvent) Reset()

func (*TopicsSubscriptionEvent) Size added in v1.3.1 

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

func (*TopicsSubscriptionEvent) String added in v1.3.1 

func (this *TopicsSubscriptionEvent) String() string

func (*TopicsSubscriptionEvent) Unmarshal added in v1.3.1 

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

func (*TopicsSubscriptionEvent) XXX_DiscardUnknown added in v1.3.1 

func (m *TopicsSubscriptionEvent) XXX_DiscardUnknown()

func (*TopicsSubscriptionEvent) XXX_Marshal added in v1.3.1 

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

func (*TopicsSubscriptionEvent) XXX_Merge added in v1.3.1 

func (m *TopicsSubscriptionEvent) XXX_Merge(src proto.Message)

func (*TopicsSubscriptionEvent) XXX_Size added in v1.3.1 

func (m *TopicsSubscriptionEvent) XXX_Size() int

func (*TopicsSubscriptionEvent) XXX_Unmarshal added in v1.3.1 

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

type TopicsSubscriptionEventType added in v1.3.1 

type TopicsSubscriptionEventType int32
const (
	TopicsSubscriptionEventType_SubscriptionEventTypeUndefined      TopicsSubscriptionEventType = 0
	TopicsSubscriptionEventType_SubscriptionEventTypeSubscribe      TopicsSubscriptionEventType = 1
	TopicsSubscriptionEventType_SubscriptionEventTypeReSync         TopicsSubscriptionEventType = 2
	TopicsSubscriptionEventType_SubscriptionEventTypeReSyncComplete TopicsSubscriptionEventType = 3
	TopicsSubscriptionEventType_SubscriptionEventTypeHeartbeat      TopicsSubscriptionEventType = 4
	TopicsSubscriptionEventType_SubscriptionEventTypeLeave          TopicsSubscriptionEventType = 5
	TopicsSubscriptionEventType_SubscriptionEventTypeGroupState     TopicsSubscriptionEventType = 6
)

func (TopicsSubscriptionEventType) EnumDescriptor added in v1.3.1 

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

func (TopicsSubscriptionEventType) String added in v1.3.1 

func (x TopicsSubscriptionEventType) String() string

type TopicsSubscriptionOffsetType added in v1.3.1 

type TopicsSubscriptionOffsetType int32
const (
	TopicsSubscriptionOffsetType_SubscriptionOffsetTypeUndefined TopicsSubscriptionOffsetType = 0
	TopicsSubscriptionOffsetType_StartNewOnly                    TopicsSubscriptionOffsetType = 1
	TopicsSubscriptionOffsetType_StartFromFirst                  TopicsSubscriptionOffsetType = 2
	TopicsSubscriptionOffsetType_StartFromLast                   TopicsSubscriptionOffsetType = 3
	TopicsSubscriptionOffsetType_StartAtSequence                 TopicsSubscriptionOffsetType = 4
	TopicsSubscriptionOffsetType_StartAtTime                     TopicsSubscriptionOffsetType = 5
	TopicsSubscriptionOffsetType_StartAtTimeDelta                TopicsSubscriptionOffsetType = 6
)

func (TopicsSubscriptionOffsetType) EnumDescriptor added in v1.3.1 

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

func (TopicsSubscriptionOffsetType) String added in v1.3.1 

func (x TopicsSubscriptionOffsetType) String() string

type TopicsSubscriptionRequest added in v1.3.1 

type TopicsSubscriptionRequest struct {
	SubscriptionRequestType  TopicsSubscriptionRequestType  `` /* 142-byte string literal not displayed */
	Topics                   []string                       `protobuf:"bytes,2,rep,name=Topics,proto3" json:"Topics,omitempty"`
	TopicPartitions          []*TopicPartition              `protobuf:"bytes,3,rep,name=TopicPartitions,proto3" json:"TopicPartitions,omitempty"`
	GroupID                  string                         `protobuf:"bytes,4,opt,name=GroupID,proto3" json:"GroupID,omitempty"`
	MemberID                 string                         `protobuf:"bytes,5,opt,name=MemberID,proto3" json:"MemberID,omitempty"`
	IsStatic                 bool                           `protobuf:"varint,6,opt,name=IsStatic,proto3" json:"IsStatic,omitempty"`
	SubscriptionStrategyType TopicsSubscriptionStrategyType `` /* 145-byte string literal not displayed */
	SubscriptionOffsetType   TopicsSubscriptionOffsetType   `` /* 139-byte string literal not displayed */
	XXX_NoUnkeyedLiteral     struct{}                       `json:"-"`
	XXX_unrecognized         []byte                         `json:"-"`
	XXX_sizecache            int32                          `json:"-"`
}

func NewPopulatedTopicsSubscriptionRequest added in v1.3.1 

func NewPopulatedTopicsSubscriptionRequest(r randyKubemqGo, easy bool) *TopicsSubscriptionRequest

func (*TopicsSubscriptionRequest) Descriptor added in v1.3.1 

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

func (*TopicsSubscriptionRequest) Equal added in v1.3.1 

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

func (*TopicsSubscriptionRequest) GetGroupID added in v1.3.1 

func (m *TopicsSubscriptionRequest) GetGroupID() string

func (*TopicsSubscriptionRequest) GetIsStatic added in v1.3.1 

func (m *TopicsSubscriptionRequest) GetIsStatic() bool

func (*TopicsSubscriptionRequest) GetMemberID added in v1.3.1 

func (m *TopicsSubscriptionRequest) GetMemberID() string

func (*TopicsSubscriptionRequest) GetSubscriptionOffsetType added in v1.3.1 

func (m *TopicsSubscriptionRequest) GetSubscriptionOffsetType() TopicsSubscriptionOffsetType

func (*TopicsSubscriptionRequest) GetSubscriptionRequestType added in v1.3.1 

func (m *TopicsSubscriptionRequest) GetSubscriptionRequestType() TopicsSubscriptionRequestType

func (*TopicsSubscriptionRequest) GetSubscriptionStrategyType added in v1.3.1 

func (m *TopicsSubscriptionRequest) GetSubscriptionStrategyType() TopicsSubscriptionStrategyType

func (*TopicsSubscriptionRequest) GetTopicPartitions added in v1.3.1 

func (m *TopicsSubscriptionRequest) GetTopicPartitions() []*TopicPartition

func (*TopicsSubscriptionRequest) GetTopics added in v1.3.1 

func (m *TopicsSubscriptionRequest) GetTopics() []string

func (*TopicsSubscriptionRequest) GoString added in v1.3.1 

func (this *TopicsSubscriptionRequest) GoString() string

func (*TopicsSubscriptionRequest) Marshal added in v1.3.1 

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

func (*TopicsSubscriptionRequest) MarshalTo added in v1.3.1 

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

func (*TopicsSubscriptionRequest) ProtoMessage added in v1.3.1 

func (*TopicsSubscriptionRequest) ProtoMessage()

func (*TopicsSubscriptionRequest) Reset added in v1.3.1 

func (m *TopicsSubscriptionRequest) Reset()

func (*TopicsSubscriptionRequest) Size added in v1.3.1 

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

func (*TopicsSubscriptionRequest) String added in v1.3.1 

func (this *TopicsSubscriptionRequest) String() string

func (*TopicsSubscriptionRequest) Unmarshal added in v1.3.1 

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

func (*TopicsSubscriptionRequest) XXX_DiscardUnknown added in v1.3.1 

func (m *TopicsSubscriptionRequest) XXX_DiscardUnknown()

func (*TopicsSubscriptionRequest) XXX_Marshal added in v1.3.1 

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

func (*TopicsSubscriptionRequest) XXX_Merge added in v1.3.1 

func (m *TopicsSubscriptionRequest) XXX_Merge(src proto.Message)

func (*TopicsSubscriptionRequest) XXX_Size added in v1.3.1 

func (m *TopicsSubscriptionRequest) XXX_Size() int

func (*TopicsSubscriptionRequest) XXX_Unmarshal added in v1.3.1 

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

type TopicsSubscriptionRequestType added in v1.3.1 

type TopicsSubscriptionRequestType int32
const (
	TopicsSubscriptionRequestType_SubscriptionRequestTypeUndefined TopicsSubscriptionRequestType = 0
	TopicsSubscriptionRequestType_SubscriptionRequestTypeJoin      TopicsSubscriptionRequestType = 1
	TopicsSubscriptionRequestType_SubscriptionRequestTypeLeave     TopicsSubscriptionRequestType = 2
)

func (TopicsSubscriptionRequestType) EnumDescriptor added in v1.3.1 

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

func (TopicsSubscriptionRequestType) String added in v1.3.1 

func (x TopicsSubscriptionRequestType) String() string

type TopicsSubscriptionStrategyType added in v1.3.1 

type TopicsSubscriptionStrategyType int32
const (
	TopicsSubscriptionStrategyType_SubscriptionStrategyTypeUndefined TopicsSubscriptionStrategyType = 0
	TopicsSubscriptionStrategyType_Range                             TopicsSubscriptionStrategyType = 1
	TopicsSubscriptionStrategyType_RoundRobin                        TopicsSubscriptionStrategyType = 2
	TopicsSubscriptionStrategyType_Sticky                            TopicsSubscriptionStrategyType = 3
)

func (TopicsSubscriptionStrategyType) EnumDescriptor added in v1.3.1 

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

func (TopicsSubscriptionStrategyType) String added in v1.3.1 

func (x TopicsSubscriptionStrategyType) String() string

type TopicsUpstreamRequest added in v1.3.1 

type TopicsUpstreamRequest struct {
	RequestID            string                    `protobuf:"bytes,1,opt,name=RequestID,proto3" json:"RequestID,omitempty"`
	RequestTypeData      TopicsUpstreamRequestType `protobuf:"varint,2,opt,name=RequestTypeData,proto3,enum=kubemq.TopicsUpstreamRequestType" json:"RequestTypeData,omitempty"`
	ClientID             string                    `protobuf:"bytes,3,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	Messages             []*QueueMessage           `protobuf:"bytes,4,rep,name=Messages,proto3" json:"Messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func NewPopulatedTopicsUpstreamRequest added in v1.3.1 

func NewPopulatedTopicsUpstreamRequest(r randyKubemqGo, easy bool) *TopicsUpstreamRequest

func (*TopicsUpstreamRequest) Descriptor added in v1.3.1 

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

func (*TopicsUpstreamRequest) Equal added in v1.3.1 

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

func (*TopicsUpstreamRequest) GetClientID added in v1.3.1 

func (m *TopicsUpstreamRequest) GetClientID() string

func (*TopicsUpstreamRequest) GetMessages added in v1.3.1 

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

func (*TopicsUpstreamRequest) GetRequestID added in v1.3.1 

func (m *TopicsUpstreamRequest) GetRequestID() string

func (*TopicsUpstreamRequest) GetRequestTypeData added in v1.3.1 

func (m *TopicsUpstreamRequest) GetRequestTypeData() TopicsUpstreamRequestType

func (*TopicsUpstreamRequest) GoString added in v1.3.1 

func (this *TopicsUpstreamRequest) GoString() string

func (*TopicsUpstreamRequest) Marshal added in v1.3.1 

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

func (*TopicsUpstreamRequest) MarshalTo added in v1.3.1 

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

func (*TopicsUpstreamRequest) ProtoMessage added in v1.3.1 

func (*TopicsUpstreamRequest) ProtoMessage()

func (*TopicsUpstreamRequest) Reset added in v1.3.1 

func (m *TopicsUpstreamRequest) Reset()

func (*TopicsUpstreamRequest) Size added in v1.3.1 

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

func (*TopicsUpstreamRequest) String added in v1.3.1 

func (this *TopicsUpstreamRequest) String() string

func (*TopicsUpstreamRequest) Unmarshal added in v1.3.1 

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

func (*TopicsUpstreamRequest) XXX_DiscardUnknown added in v1.3.1 

func (m *TopicsUpstreamRequest) XXX_DiscardUnknown()

func (*TopicsUpstreamRequest) XXX_Marshal added in v1.3.1 

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

func (*TopicsUpstreamRequest) XXX_Merge added in v1.3.1 

func (m *TopicsUpstreamRequest) XXX_Merge(src proto.Message)

func (*TopicsUpstreamRequest) XXX_Size added in v1.3.1 

func (m *TopicsUpstreamRequest) XXX_Size() int

func (*TopicsUpstreamRequest) XXX_Unmarshal added in v1.3.1 

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

type TopicsUpstreamRequestType added in v1.3.1 

type TopicsUpstreamRequestType int32
const (
	TopicsUpstreamRequestType_TopicsUpstreamRequestUnknown TopicsUpstreamRequestType = 0
	TopicsUpstreamRequestType_FireAndForget                TopicsUpstreamRequestType = 1
	TopicsUpstreamRequestType_SendAsync                    TopicsUpstreamRequestType = 2
	TopicsUpstreamRequestType_SendSync                     TopicsUpstreamRequestType = 3
)

func (TopicsUpstreamRequestType) EnumDescriptor added in v1.3.1 

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

func (TopicsUpstreamRequestType) String added in v1.3.1 

func (x TopicsUpstreamRequestType) String() string

type TopicsUpstreamResponse added in v1.3.1 

type TopicsUpstreamResponse struct {
	RefRequestID         string                       `protobuf:"bytes,1,opt,name=RefRequestID,proto3" json:"RefRequestID,omitempty"`
	RequestTypeData      TopicsUpstreamRequestType    `protobuf:"varint,2,opt,name=RequestTypeData,proto3,enum=kubemq.TopicsUpstreamRequestType" json:"RequestTypeData,omitempty"`
	TopicResults         map[string]*SendTopicResults `` /* 165-byte string literal not displayed */
	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_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func NewPopulatedTopicsUpstreamResponse added in v1.3.1 

func NewPopulatedTopicsUpstreamResponse(r randyKubemqGo, easy bool) *TopicsUpstreamResponse

func (*TopicsUpstreamResponse) Descriptor added in v1.3.1 

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

func (*TopicsUpstreamResponse) Equal added in v1.3.1 

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

func (*TopicsUpstreamResponse) GetError added in v1.3.1 

func (m *TopicsUpstreamResponse) GetError() string

func (*TopicsUpstreamResponse) GetIsError added in v1.3.1 

func (m *TopicsUpstreamResponse) GetIsError() bool

func (*TopicsUpstreamResponse) GetRefRequestID added in v1.3.1 

func (m *TopicsUpstreamResponse) GetRefRequestID() string

func (*TopicsUpstreamResponse) GetRequestTypeData added in v1.3.1 

func (m *TopicsUpstreamResponse) GetRequestTypeData() TopicsUpstreamRequestType

func (*TopicsUpstreamResponse) GetTopicResults added in v1.3.1 

func (m *TopicsUpstreamResponse) GetTopicResults() map[string]*SendTopicResults

func (*TopicsUpstreamResponse) GoString added in v1.3.1 

func (this *TopicsUpstreamResponse) GoString() string

func (*TopicsUpstreamResponse) Marshal added in v1.3.1 

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

func (*TopicsUpstreamResponse) MarshalTo added in v1.3.1 

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

func (*TopicsUpstreamResponse) ProtoMessage added in v1.3.1 

func (*TopicsUpstreamResponse) ProtoMessage()

func (*TopicsUpstreamResponse) Reset added in v1.3.1 

func (m *TopicsUpstreamResponse) Reset()

func (*TopicsUpstreamResponse) Size added in v1.3.1 

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

func (*TopicsUpstreamResponse) String added in v1.3.1 

func (this *TopicsUpstreamResponse) String() string

func (*TopicsUpstreamResponse) Unmarshal added in v1.3.1 

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

func (*TopicsUpstreamResponse) XXX_DiscardUnknown added in v1.3.1 

func (m *TopicsUpstreamResponse) XXX_DiscardUnknown()

func (*TopicsUpstreamResponse) XXX_Marshal added in v1.3.1 

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

func (*TopicsUpstreamResponse) XXX_Merge added in v1.3.1 

func (m *TopicsUpstreamResponse) XXX_Merge(src proto.Message)

func (*TopicsUpstreamResponse) XXX_Size added in v1.3.1 

func (m *TopicsUpstreamResponse) XXX_Size() int

func (*TopicsUpstreamResponse) XXX_Unmarshal added in v1.3.1 

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

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.