proto

package
v0.0.0-...-3d1347b Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	MessageService_PublishMessages_FullMethodName     = "/message.MessageService/PublishMessages"
	MessageService_CreateConsumer_FullMethodName      = "/message.MessageService/CreateConsumer"
	MessageService_CreateConsumerGroup_FullMethodName = "/message.MessageService/CreateConsumerGroup"
	MessageService_GetConsumerGroups_FullMethodName   = "/message.MessageService/GetConsumerGroups"
	MessageService_Consume_FullMethodName             = "/message.MessageService/Consume"
	MessageService_CreateTopic_FullMethodName         = "/message.MessageService/CreateTopic"
	MessageService_AckConsume_FullMethodName          = "/message.MessageService/AckConsume"
	MessageService_GetMeta_FullMethodName             = "/message.MessageService/GetMeta"
)

Variables

View Source 
var (
	Operation_name = map[int32]string{
		0: "PUBLISH",
		1: "ACK",
		2: "CREATE_CONSUMER",
		3: "CREATE_TOPIC",
		4: "ADD_MEMBER",
		5: "REMOVE_MEMBER",
		6: "CREATE_CONSUMER_GROUP",
	}
	Operation_value = map[string]int32{
		"PUBLISH":               0,
		"ACK":                   1,
		"CREATE_CONSUMER":       2,
		"CREATE_TOPIC":          3,
		"ADD_MEMBER":            4,
		"REMOVE_MEMBER":         5,
		"CREATE_CONSUMER_GROUP": 6,
	}
)

Enum value maps for Operation.

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_service_proto protoreflect.FileDescriptor
View Source 
var MessageService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "message.MessageService",
	HandlerType: (*MessageServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PublishMessages",
			Handler:    _MessageService_PublishMessages_Handler,
		},
		{
			MethodName: "CreateConsumer",
			Handler:    _MessageService_CreateConsumer_Handler,
		},
		{
			MethodName: "CreateConsumerGroup",
			Handler:    _MessageService_CreateConsumerGroup_Handler,
		},
		{
			MethodName: "GetConsumerGroups",
			Handler:    _MessageService_GetConsumerGroups_Handler,
		},
		{
			MethodName: "Consume",
			Handler:    _MessageService_Consume_Handler,
		},
		{
			MethodName: "CreateTopic",
			Handler:    _MessageService_CreateTopic_Handler,
		},
		{
			MethodName: "AckConsume",
			Handler:    _MessageService_AckConsume_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _MessageService_GetMeta_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "service.proto",
}

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

Functions

func RegisterMessageServiceServer 

func RegisterMessageServiceServer(s grpc.ServiceRegistrar, srv MessageServiceServer)

Types

type Ack 

type Ack struct {
	Offsets map[uint64]uint64 `` /* 157-byte string literal not displayed */
	GroupId string            `protobuf:"bytes,2,opt,name=groupId,proto3" json:"groupId,omitempty"`
	Topic   string            `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*Ack) Descriptor deprecated 

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

Deprecated: Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) GetGroupId 

func (x *Ack) GetGroupId() string

func (*Ack) GetOffsets 

func (x *Ack) GetOffsets() map[uint64]uint64

func (*Ack) GetTopic 

func (x *Ack) GetTopic() string

func (*Ack) MarshalToSizedBufferVT 

func (m *Ack) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Ack) MarshalToVT 

func (m *Ack) MarshalToVT(dAtA []byte) (int, error)

func (*Ack) MarshalVT 

func (m *Ack) MarshalVT() (dAtA []byte, err error)

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect 

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

func (*Ack) Reset 

func (x *Ack) Reset()

func (*Ack) SizeVT 

func (m *Ack) SizeVT() (n int)

func (*Ack) String 

func (x *Ack) String() string

func (*Ack) UnmarshalVT 

func (m *Ack) UnmarshalVT(dAtA []byte) error

type AckConsumeRequest 

type AckConsumeRequest struct {
	Offsets map[uint64]uint64 `` /* 157-byte string literal not displayed */
	GroupId string            `protobuf:"bytes,2,opt,name=groupId,proto3" json:"groupId,omitempty"`
	Topic   string            `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*AckConsumeRequest) Descriptor deprecated 

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

Deprecated: Use AckConsumeRequest.ProtoReflect.Descriptor instead.

func (*AckConsumeRequest) GetGroupId 

func (x *AckConsumeRequest) GetGroupId() string

func (*AckConsumeRequest) GetOffsets 

func (x *AckConsumeRequest) GetOffsets() map[uint64]uint64

func (*AckConsumeRequest) GetTopic 

func (x *AckConsumeRequest) GetTopic() string

func (*AckConsumeRequest) MarshalToSizedBufferVT 

func (m *AckConsumeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AckConsumeRequest) MarshalToVT 

func (m *AckConsumeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*AckConsumeRequest) MarshalVT 

func (m *AckConsumeRequest) MarshalVT() (dAtA []byte, err error)

func (*AckConsumeRequest) ProtoMessage 

func (*AckConsumeRequest) ProtoMessage()

func (*AckConsumeRequest) ProtoReflect 

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

func (*AckConsumeRequest) Reset 

func (x *AckConsumeRequest) Reset()

func (*AckConsumeRequest) SizeVT 

func (m *AckConsumeRequest) SizeVT() (n int)

func (*AckConsumeRequest) String 

func (x *AckConsumeRequest) String() string

func (*AckConsumeRequest) UnmarshalVT 

func (m *AckConsumeRequest) UnmarshalVT(dAtA []byte) error

type AckConsumeResponse 

type AckConsumeResponse struct {
	// contains filtered or unexported fields
}

func (*AckConsumeResponse) Descriptor deprecated 

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

Deprecated: Use AckConsumeResponse.ProtoReflect.Descriptor instead.

func (*AckConsumeResponse) MarshalToSizedBufferVT 

func (m *AckConsumeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AckConsumeResponse) MarshalToVT 

func (m *AckConsumeResponse) MarshalToVT(dAtA []byte) (int, error)

func (*AckConsumeResponse) MarshalVT 

func (m *AckConsumeResponse) MarshalVT() (dAtA []byte, err error)

func (*AckConsumeResponse) ProtoMessage 

func (*AckConsumeResponse) ProtoMessage()

func (*AckConsumeResponse) ProtoReflect 

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

func (*AckConsumeResponse) Reset 

func (x *AckConsumeResponse) Reset()

func (*AckConsumeResponse) SizeVT 

func (m *AckConsumeResponse) SizeVT() (n int)

func (*AckConsumeResponse) String 

func (x *AckConsumeResponse) String() string

func (*AckConsumeResponse) UnmarshalVT 

func (m *AckConsumeResponse) UnmarshalVT(dAtA []byte) error

type AckResult 

type AckResult struct {
	// contains filtered or unexported fields
}

func (*AckResult) Descriptor deprecated 

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

Deprecated: Use AckResult.ProtoReflect.Descriptor instead.

func (*AckResult) MarshalToSizedBufferVT 

func (m *AckResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AckResult) MarshalToVT 

func (m *AckResult) MarshalToVT(dAtA []byte) (int, error)

func (*AckResult) MarshalVT 

func (m *AckResult) MarshalVT() (dAtA []byte, err error)

func (*AckResult) ProtoMessage 

func (*AckResult) ProtoMessage()

func (*AckResult) ProtoReflect 

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

func (*AckResult) Reset 

func (x *AckResult) Reset()

func (*AckResult) SizeVT 

func (m *AckResult) SizeVT() (n int)

func (*AckResult) String 

func (x *AckResult) String() string

func (*AckResult) UnmarshalVT 

func (m *AckResult) UnmarshalVT(dAtA []byte) error

type AddMember 

type AddMember struct {
	NodeId  string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*AddMember) Descriptor deprecated 

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

Deprecated: Use AddMember.ProtoReflect.Descriptor instead.

func (*AddMember) GetAddress 

func (x *AddMember) GetAddress() string

func (*AddMember) GetNodeId 

func (x *AddMember) GetNodeId() string

func (*AddMember) MarshalToSizedBufferVT 

func (m *AddMember) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AddMember) MarshalToVT 

func (m *AddMember) MarshalToVT(dAtA []byte) (int, error)

func (*AddMember) MarshalVT 

func (m *AddMember) MarshalVT() (dAtA []byte, err error)

func (*AddMember) ProtoMessage 

func (*AddMember) ProtoMessage()

func (*AddMember) ProtoReflect 

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

func (*AddMember) Reset 

func (x *AddMember) Reset()

func (*AddMember) SizeVT 

func (m *AddMember) SizeVT() (n int)

func (*AddMember) String 

func (x *AddMember) String() string

func (*AddMember) UnmarshalVT 

func (m *AddMember) UnmarshalVT(dAtA []byte) error

type AddMemberResult 

type AddMemberResult struct {
	// contains filtered or unexported fields
}

func (*AddMemberResult) Descriptor deprecated 

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

Deprecated: Use AddMemberResult.ProtoReflect.Descriptor instead.

func (*AddMemberResult) MarshalToSizedBufferVT 

func (m *AddMemberResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AddMemberResult) MarshalToVT 

func (m *AddMemberResult) MarshalToVT(dAtA []byte) (int, error)

func (*AddMemberResult) MarshalVT 

func (m *AddMemberResult) MarshalVT() (dAtA []byte, err error)

func (*AddMemberResult) ProtoMessage 

func (*AddMemberResult) ProtoMessage()

func (*AddMemberResult) ProtoReflect 

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

func (*AddMemberResult) Reset 

func (x *AddMemberResult) Reset()

func (*AddMemberResult) SizeVT 

func (m *AddMemberResult) SizeVT() (n int)

func (*AddMemberResult) String 

func (x *AddMemberResult) String() string

func (*AddMemberResult) UnmarshalVT 

func (m *AddMemberResult) UnmarshalVT(dAtA []byte) error

type ConsumeRequest 

type ConsumeRequest struct {
	Topic   string            `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	GroupId string            `protobuf:"bytes,2,opt,name=groupId,proto3" json:"groupId,omitempty"`
	Offsets map[uint64]uint64 `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConsumeRequest) Descriptor deprecated 

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

Deprecated: Use ConsumeRequest.ProtoReflect.Descriptor instead.

func (*ConsumeRequest) GetGroupId 

func (x *ConsumeRequest) GetGroupId() string

func (*ConsumeRequest) GetOffsets 

func (x *ConsumeRequest) GetOffsets() map[uint64]uint64

func (*ConsumeRequest) GetTopic 

func (x *ConsumeRequest) GetTopic() string

func (*ConsumeRequest) MarshalToSizedBufferVT 

func (m *ConsumeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ConsumeRequest) MarshalToVT 

func (m *ConsumeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ConsumeRequest) MarshalVT 

func (m *ConsumeRequest) MarshalVT() (dAtA []byte, err error)

func (*ConsumeRequest) ProtoMessage 

func (*ConsumeRequest) ProtoMessage()

func (*ConsumeRequest) ProtoReflect 

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

func (*ConsumeRequest) Reset 

func (x *ConsumeRequest) Reset()

func (*ConsumeRequest) SizeVT 

func (m *ConsumeRequest) SizeVT() (n int)

func (*ConsumeRequest) String 

func (x *ConsumeRequest) String() string

func (*ConsumeRequest) UnmarshalVT 

func (m *ConsumeRequest) UnmarshalVT(dAtA []byte) error

type ConsumeResponse 

type ConsumeResponse struct {
	Messages  map[uint64]*Messages `` /* 158-byte string literal not displayed */
	LastIndex uint64               `protobuf:"varint,2,opt,name=lastIndex,proto3" json:"lastIndex,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumeResponse) Descriptor deprecated 

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

Deprecated: Use ConsumeResponse.ProtoReflect.Descriptor instead.

func (*ConsumeResponse) GetLastIndex 

func (x *ConsumeResponse) GetLastIndex() uint64

func (*ConsumeResponse) GetMessages 

func (x *ConsumeResponse) GetMessages() map[uint64]*Messages

func (*ConsumeResponse) MarshalToSizedBufferVT 

func (m *ConsumeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ConsumeResponse) MarshalToVT 

func (m *ConsumeResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ConsumeResponse) MarshalVT 

func (m *ConsumeResponse) MarshalVT() (dAtA []byte, err error)

func (*ConsumeResponse) ProtoMessage 

func (*ConsumeResponse) ProtoMessage()

func (*ConsumeResponse) ProtoReflect 

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

func (*ConsumeResponse) Reset 

func (x *ConsumeResponse) Reset()

func (*ConsumeResponse) SizeVT 

func (m *ConsumeResponse) SizeVT() (n int)

func (*ConsumeResponse) String 

func (x *ConsumeResponse) String() string

func (*ConsumeResponse) UnmarshalVT 

func (m *ConsumeResponse) UnmarshalVT(dAtA []byte) error

type Consumer 

type Consumer struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Partition uint64 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset    uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*Consumer) Descriptor deprecated 

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

Deprecated: Use Consumer.ProtoReflect.Descriptor instead.

func (*Consumer) GetId 

func (x *Consumer) GetId() string

func (*Consumer) GetOffset 

func (x *Consumer) GetOffset() uint64

func (*Consumer) GetPartition 

func (x *Consumer) GetPartition() uint64

func (*Consumer) MarshalToSizedBufferVT 

func (m *Consumer) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Consumer) MarshalToVT 

func (m *Consumer) MarshalToVT(dAtA []byte) (int, error)

func (*Consumer) MarshalVT 

func (m *Consumer) MarshalVT() (dAtA []byte, err error)

func (*Consumer) ProtoMessage 

func (*Consumer) ProtoMessage()

func (*Consumer) ProtoReflect 

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

func (*Consumer) Reset 

func (x *Consumer) Reset()

func (*Consumer) SizeVT 

func (m *Consumer) SizeVT() (n int)

func (*Consumer) String 

func (x *Consumer) String() string

func (*Consumer) UnmarshalVT 

func (m *Consumer) UnmarshalVT(dAtA []byte) error

type ConsumerGroup 

type ConsumerGroup struct {
	Id        string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Consumers map[string]*Consumer `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConsumerGroup) Descriptor deprecated 

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

Deprecated: Use ConsumerGroup.ProtoReflect.Descriptor instead.

func (*ConsumerGroup) GetConsumers 

func (x *ConsumerGroup) GetConsumers() map[string]*Consumer

func (*ConsumerGroup) GetId 

func (x *ConsumerGroup) GetId() string

func (*ConsumerGroup) MarshalToSizedBufferVT 

func (m *ConsumerGroup) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ConsumerGroup) MarshalToVT 

func (m *ConsumerGroup) MarshalToVT(dAtA []byte) (int, error)

func (*ConsumerGroup) MarshalVT 

func (m *ConsumerGroup) MarshalVT() (dAtA []byte, err error)

func (*ConsumerGroup) ProtoMessage 

func (*ConsumerGroup) ProtoMessage()

func (*ConsumerGroup) ProtoReflect 

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

func (*ConsumerGroup) Reset 

func (x *ConsumerGroup) Reset()

func (*ConsumerGroup) SizeVT 

func (m *ConsumerGroup) SizeVT() (n int)

func (*ConsumerGroup) String 

func (x *ConsumerGroup) String() string

func (*ConsumerGroup) UnmarshalVT 

func (m *ConsumerGroup) UnmarshalVT(dAtA []byte) error

type CreateConsumer 

type CreateConsumer struct {
	Topic   string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	GroupId string `protobuf:"bytes,2,opt,name=groupId,proto3" json:"groupId,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateConsumer) Descriptor deprecated 

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

Deprecated: Use CreateConsumer.ProtoReflect.Descriptor instead.

func (*CreateConsumer) GetGroupId 

func (x *CreateConsumer) GetGroupId() string

func (*CreateConsumer) GetTopic 

func (x *CreateConsumer) GetTopic() string

func (*CreateConsumer) MarshalToSizedBufferVT 

func (m *CreateConsumer) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateConsumer) MarshalToVT 

func (m *CreateConsumer) MarshalToVT(dAtA []byte) (int, error)

func (*CreateConsumer) MarshalVT 

func (m *CreateConsumer) MarshalVT() (dAtA []byte, err error)

func (*CreateConsumer) ProtoMessage 

func (*CreateConsumer) ProtoMessage()

func (*CreateConsumer) ProtoReflect 

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

func (*CreateConsumer) Reset 

func (x *CreateConsumer) Reset()

func (*CreateConsumer) SizeVT 

func (m *CreateConsumer) SizeVT() (n int)

func (*CreateConsumer) String 

func (x *CreateConsumer) String() string

func (*CreateConsumer) UnmarshalVT 

func (m *CreateConsumer) UnmarshalVT(dAtA []byte) error

type CreateConsumerGroup 

type CreateConsumerGroup struct {
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Id    string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateConsumerGroup) Descriptor deprecated 

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

Deprecated: Use CreateConsumerGroup.ProtoReflect.Descriptor instead.

func (*CreateConsumerGroup) GetId 

func (x *CreateConsumerGroup) GetId() string

func (*CreateConsumerGroup) GetTopic 

func (x *CreateConsumerGroup) GetTopic() string

func (*CreateConsumerGroup) MarshalToSizedBufferVT 

func (m *CreateConsumerGroup) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateConsumerGroup) MarshalToVT 

func (m *CreateConsumerGroup) MarshalToVT(dAtA []byte) (int, error)

func (*CreateConsumerGroup) MarshalVT 

func (m *CreateConsumerGroup) MarshalVT() (dAtA []byte, err error)

func (*CreateConsumerGroup) ProtoMessage 

func (*CreateConsumerGroup) ProtoMessage()

func (*CreateConsumerGroup) ProtoReflect 

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

func (*CreateConsumerGroup) Reset 

func (x *CreateConsumerGroup) Reset()

func (*CreateConsumerGroup) SizeVT 

func (m *CreateConsumerGroup) SizeVT() (n int)

func (*CreateConsumerGroup) String 

func (x *CreateConsumerGroup) String() string

func (*CreateConsumerGroup) UnmarshalVT 

func (m *CreateConsumerGroup) UnmarshalVT(dAtA []byte) error

type CreateConsumerGroupRequest 

type CreateConsumerGroupRequest struct {
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Id    string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateConsumerGroupRequest) Descriptor deprecated 

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

Deprecated: Use CreateConsumerGroupRequest.ProtoReflect.Descriptor instead.

func (*CreateConsumerGroupRequest) GetId 

func (x *CreateConsumerGroupRequest) GetId() string

func (*CreateConsumerGroupRequest) GetTopic 

func (x *CreateConsumerGroupRequest) GetTopic() string

func (*CreateConsumerGroupRequest) MarshalToSizedBufferVT 

func (m *CreateConsumerGroupRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateConsumerGroupRequest) MarshalToVT 

func (m *CreateConsumerGroupRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CreateConsumerGroupRequest) MarshalVT 

func (m *CreateConsumerGroupRequest) MarshalVT() (dAtA []byte, err error)

func (*CreateConsumerGroupRequest) ProtoMessage 

func (*CreateConsumerGroupRequest) ProtoMessage()

func (*CreateConsumerGroupRequest) ProtoReflect 

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

func (*CreateConsumerGroupRequest) Reset 

func (x *CreateConsumerGroupRequest) Reset()

func (*CreateConsumerGroupRequest) SizeVT 

func (m *CreateConsumerGroupRequest) SizeVT() (n int)

func (*CreateConsumerGroupRequest) String 

func (x *CreateConsumerGroupRequest) String() string

func (*CreateConsumerGroupRequest) UnmarshalVT 

func (m *CreateConsumerGroupRequest) UnmarshalVT(dAtA []byte) error

type CreateConsumerGroupResponse 

type CreateConsumerGroupResponse struct {
	Id    string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Group *ConsumerGroup `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

uuid for consumer group id

func (*CreateConsumerGroupResponse) Descriptor deprecated 

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

Deprecated: Use CreateConsumerGroupResponse.ProtoReflect.Descriptor instead.

func (*CreateConsumerGroupResponse) GetGroup 

func (x *CreateConsumerGroupResponse) GetGroup() *ConsumerGroup

func (*CreateConsumerGroupResponse) GetId 

func (x *CreateConsumerGroupResponse) GetId() string

func (*CreateConsumerGroupResponse) MarshalToSizedBufferVT 

func (m *CreateConsumerGroupResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateConsumerGroupResponse) MarshalToVT 

func (m *CreateConsumerGroupResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CreateConsumerGroupResponse) MarshalVT 

func (m *CreateConsumerGroupResponse) MarshalVT() (dAtA []byte, err error)

func (*CreateConsumerGroupResponse) ProtoMessage 

func (*CreateConsumerGroupResponse) ProtoMessage()

func (*CreateConsumerGroupResponse) ProtoReflect 

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

func (*CreateConsumerGroupResponse) Reset 

func (x *CreateConsumerGroupResponse) Reset()

func (*CreateConsumerGroupResponse) SizeVT 

func (m *CreateConsumerGroupResponse) SizeVT() (n int)

func (*CreateConsumerGroupResponse) String 

func (x *CreateConsumerGroupResponse) String() string

func (*CreateConsumerGroupResponse) UnmarshalVT 

func (m *CreateConsumerGroupResponse) UnmarshalVT(dAtA []byte) error

type CreateConsumerGroupResult 

type CreateConsumerGroupResult struct {
	Id        string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Consumers []*Consumer `protobuf:"bytes,2,rep,name=consumers,proto3" json:"consumers,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateConsumerGroupResult) Descriptor deprecated 

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

Deprecated: Use CreateConsumerGroupResult.ProtoReflect.Descriptor instead.

func (*CreateConsumerGroupResult) GetConsumers 

func (x *CreateConsumerGroupResult) GetConsumers() []*Consumer

func (*CreateConsumerGroupResult) GetId 

func (x *CreateConsumerGroupResult) GetId() string

func (*CreateConsumerGroupResult) MarshalToSizedBufferVT 

func (m *CreateConsumerGroupResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateConsumerGroupResult) MarshalToVT 

func (m *CreateConsumerGroupResult) MarshalToVT(dAtA []byte) (int, error)

func (*CreateConsumerGroupResult) MarshalVT 

func (m *CreateConsumerGroupResult) MarshalVT() (dAtA []byte, err error)

func (*CreateConsumerGroupResult) ProtoMessage 

func (*CreateConsumerGroupResult) ProtoMessage()

func (*CreateConsumerGroupResult) ProtoReflect 

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

func (*CreateConsumerGroupResult) Reset 

func (x *CreateConsumerGroupResult) Reset()

func (*CreateConsumerGroupResult) SizeVT 

func (m *CreateConsumerGroupResult) SizeVT() (n int)

func (*CreateConsumerGroupResult) String 

func (x *CreateConsumerGroupResult) String() string

func (*CreateConsumerGroupResult) UnmarshalVT 

func (m *CreateConsumerGroupResult) UnmarshalVT(dAtA []byte) error

type CreateConsumerRequest 

type CreateConsumerRequest struct {
	Topic   string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	GroupId string `protobuf:"bytes,2,opt,name=groupId,proto3" json:"groupId,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateConsumerRequest) Descriptor deprecated 

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

Deprecated: Use CreateConsumerRequest.ProtoReflect.Descriptor instead.

func (*CreateConsumerRequest) GetGroupId 

func (x *CreateConsumerRequest) GetGroupId() string

func (*CreateConsumerRequest) GetTopic 

func (x *CreateConsumerRequest) GetTopic() string

func (*CreateConsumerRequest) MarshalToSizedBufferVT 

func (m *CreateConsumerRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateConsumerRequest) MarshalToVT 

func (m *CreateConsumerRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CreateConsumerRequest) MarshalVT 

func (m *CreateConsumerRequest) MarshalVT() (dAtA []byte, err error)

func (*CreateConsumerRequest) ProtoMessage 

func (*CreateConsumerRequest) ProtoMessage()

func (*CreateConsumerRequest) ProtoReflect 

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

func (*CreateConsumerRequest) Reset 

func (x *CreateConsumerRequest) Reset()

func (*CreateConsumerRequest) SizeVT 

func (m *CreateConsumerRequest) SizeVT() (n int)

func (*CreateConsumerRequest) String 

func (x *CreateConsumerRequest) String() string

func (*CreateConsumerRequest) UnmarshalVT 

func (m *CreateConsumerRequest) UnmarshalVT(dAtA []byte) error

type CreateConsumerResponse 

type CreateConsumerResponse struct {
	ConsumerId string `protobuf:"bytes,1,opt,name=consumerId,proto3" json:"consumerId,omitempty"`
	LastIndex  uint64 `protobuf:"varint,2,opt,name=lastIndex,proto3" json:"lastIndex,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateConsumerResponse) Descriptor deprecated 

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

Deprecated: Use CreateConsumerResponse.ProtoReflect.Descriptor instead.

func (*CreateConsumerResponse) GetConsumerId 

func (x *CreateConsumerResponse) GetConsumerId() string

func (*CreateConsumerResponse) GetLastIndex 

func (x *CreateConsumerResponse) GetLastIndex() uint64

func (*CreateConsumerResponse) MarshalToSizedBufferVT 

func (m *CreateConsumerResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateConsumerResponse) MarshalToVT 

func (m *CreateConsumerResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CreateConsumerResponse) MarshalVT 

func (m *CreateConsumerResponse) MarshalVT() (dAtA []byte, err error)

func (*CreateConsumerResponse) ProtoMessage 

func (*CreateConsumerResponse) ProtoMessage()

func (*CreateConsumerResponse) ProtoReflect 

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

func (*CreateConsumerResponse) Reset 

func (x *CreateConsumerResponse) Reset()

func (*CreateConsumerResponse) SizeVT 

func (m *CreateConsumerResponse) SizeVT() (n int)

func (*CreateConsumerResponse) String 

func (x *CreateConsumerResponse) String() string

func (*CreateConsumerResponse) UnmarshalVT 

func (m *CreateConsumerResponse) UnmarshalVT(dAtA []byte) error

type CreateConsumerResult 

type CreateConsumerResult struct {
	Consumer *Consumer `protobuf:"bytes,1,opt,name=consumer,proto3" json:"consumer,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateConsumerResult) Descriptor deprecated 

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

Deprecated: Use CreateConsumerResult.ProtoReflect.Descriptor instead.

func (*CreateConsumerResult) GetConsumer 

func (x *CreateConsumerResult) GetConsumer() *Consumer

func (*CreateConsumerResult) MarshalToSizedBufferVT 

func (m *CreateConsumerResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateConsumerResult) MarshalToVT 

func (m *CreateConsumerResult) MarshalToVT(dAtA []byte) (int, error)

func (*CreateConsumerResult) MarshalVT 

func (m *CreateConsumerResult) MarshalVT() (dAtA []byte, err error)

func (*CreateConsumerResult) ProtoMessage 

func (*CreateConsumerResult) ProtoMessage()

func (*CreateConsumerResult) ProtoReflect 

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

func (*CreateConsumerResult) Reset 

func (x *CreateConsumerResult) Reset()

func (*CreateConsumerResult) SizeVT 

func (m *CreateConsumerResult) SizeVT() (n int)

func (*CreateConsumerResult) String 

func (x *CreateConsumerResult) String() string

func (*CreateConsumerResult) UnmarshalVT 

func (m *CreateConsumerResult) UnmarshalVT(dAtA []byte) error

type CreateTopic 

type CreateTopic struct {
	Topic      string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partitions []uint64 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTopic) Descriptor deprecated 

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

Deprecated: Use CreateTopic.ProtoReflect.Descriptor instead.

func (*CreateTopic) GetPartitions 

func (x *CreateTopic) GetPartitions() []uint64

func (*CreateTopic) GetTopic 

func (x *CreateTopic) GetTopic() string

func (*CreateTopic) MarshalToSizedBufferVT 

func (m *CreateTopic) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateTopic) MarshalToVT 

func (m *CreateTopic) MarshalToVT(dAtA []byte) (int, error)

func (*CreateTopic) MarshalVT 

func (m *CreateTopic) MarshalVT() (dAtA []byte, err error)

func (*CreateTopic) ProtoMessage 

func (*CreateTopic) ProtoMessage()

func (*CreateTopic) ProtoReflect 

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

func (*CreateTopic) Reset 

func (x *CreateTopic) Reset()

func (*CreateTopic) SizeVT 

func (m *CreateTopic) SizeVT() (n int)

func (*CreateTopic) String 

func (x *CreateTopic) String() string

func (*CreateTopic) UnmarshalVT 

func (m *CreateTopic) UnmarshalVT(dAtA []byte) error

type CreateTopicRequest 

type CreateTopicRequest struct {
	Topic      string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partitions []uint64 `protobuf:"varint,2,rep,packed,name=partitions,proto3" json:"partitions,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTopicRequest) Descriptor deprecated 

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

Deprecated: Use CreateTopicRequest.ProtoReflect.Descriptor instead.

func (*CreateTopicRequest) GetPartitions 

func (x *CreateTopicRequest) GetPartitions() []uint64

func (*CreateTopicRequest) GetTopic 

func (x *CreateTopicRequest) GetTopic() string

func (*CreateTopicRequest) MarshalToSizedBufferVT 

func (m *CreateTopicRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateTopicRequest) MarshalToVT 

func (m *CreateTopicRequest) MarshalToVT(dAtA []byte) (int, error)

func (*CreateTopicRequest) MarshalVT 

func (m *CreateTopicRequest) MarshalVT() (dAtA []byte, err error)

func (*CreateTopicRequest) ProtoMessage 

func (*CreateTopicRequest) ProtoMessage()

func (*CreateTopicRequest) ProtoReflect 

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

func (*CreateTopicRequest) Reset 

func (x *CreateTopicRequest) Reset()

func (*CreateTopicRequest) SizeVT 

func (m *CreateTopicRequest) SizeVT() (n int)

func (*CreateTopicRequest) String 

func (x *CreateTopicRequest) String() string

func (*CreateTopicRequest) UnmarshalVT 

func (m *CreateTopicRequest) UnmarshalVT(dAtA []byte) error

type CreateTopicResponse 

type CreateTopicResponse struct {
	// contains filtered or unexported fields
}

func (*CreateTopicResponse) Descriptor deprecated 

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

Deprecated: Use CreateTopicResponse.ProtoReflect.Descriptor instead.

func (*CreateTopicResponse) MarshalToSizedBufferVT 

func (m *CreateTopicResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateTopicResponse) MarshalToVT 

func (m *CreateTopicResponse) MarshalToVT(dAtA []byte) (int, error)

func (*CreateTopicResponse) MarshalVT 

func (m *CreateTopicResponse) MarshalVT() (dAtA []byte, err error)

func (*CreateTopicResponse) ProtoMessage 

func (*CreateTopicResponse) ProtoMessage()

func (*CreateTopicResponse) ProtoReflect 

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

func (*CreateTopicResponse) Reset 

func (x *CreateTopicResponse) Reset()

func (*CreateTopicResponse) SizeVT 

func (m *CreateTopicResponse) SizeVT() (n int)

func (*CreateTopicResponse) String 

func (x *CreateTopicResponse) String() string

func (*CreateTopicResponse) UnmarshalVT 

func (m *CreateTopicResponse) UnmarshalVT(dAtA []byte) error

type CreateTopicResult 

type CreateTopicResult struct {
	// contains filtered or unexported fields
}

func (*CreateTopicResult) Descriptor deprecated 

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

Deprecated: Use CreateTopicResult.ProtoReflect.Descriptor instead.

func (*CreateTopicResult) MarshalToSizedBufferVT 

func (m *CreateTopicResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CreateTopicResult) MarshalToVT 

func (m *CreateTopicResult) MarshalToVT(dAtA []byte) (int, error)

func (*CreateTopicResult) MarshalVT 

func (m *CreateTopicResult) MarshalVT() (dAtA []byte, err error)

func (*CreateTopicResult) ProtoMessage 

func (*CreateTopicResult) ProtoMessage()

func (*CreateTopicResult) ProtoReflect 

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

func (*CreateTopicResult) Reset 

func (x *CreateTopicResult) Reset()

func (*CreateTopicResult) SizeVT 

func (m *CreateTopicResult) SizeVT() (n int)

func (*CreateTopicResult) String 

func (x *CreateTopicResult) String() string

func (*CreateTopicResult) UnmarshalVT 

func (m *CreateTopicResult) UnmarshalVT(dAtA []byte) error

type GetConsumerGroupsRequest 

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

func (*GetConsumerGroupsRequest) Descriptor deprecated 

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

Deprecated: Use GetConsumerGroupsRequest.ProtoReflect.Descriptor instead.

func (*GetConsumerGroupsRequest) GetTopic 

func (x *GetConsumerGroupsRequest) GetTopic() string

func (*GetConsumerGroupsRequest) MarshalToSizedBufferVT 

func (m *GetConsumerGroupsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetConsumerGroupsRequest) MarshalToVT 

func (m *GetConsumerGroupsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetConsumerGroupsRequest) MarshalVT 

func (m *GetConsumerGroupsRequest) MarshalVT() (dAtA []byte, err error)

func (*GetConsumerGroupsRequest) ProtoMessage 

func (*GetConsumerGroupsRequest) ProtoMessage()

func (*GetConsumerGroupsRequest) ProtoReflect 

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

func (*GetConsumerGroupsRequest) Reset 

func (x *GetConsumerGroupsRequest) Reset()

func (*GetConsumerGroupsRequest) SizeVT 

func (m *GetConsumerGroupsRequest) SizeVT() (n int)

func (*GetConsumerGroupsRequest) String 

func (x *GetConsumerGroupsRequest) String() string

func (*GetConsumerGroupsRequest) UnmarshalVT 

func (m *GetConsumerGroupsRequest) UnmarshalVT(dAtA []byte) error

type GetConsumerGroupsResponse 

type GetConsumerGroupsResponse struct {
	Groups map[string]*ConsumerGroup `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetConsumerGroupsResponse) Descriptor deprecated 

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

Deprecated: Use GetConsumerGroupsResponse.ProtoReflect.Descriptor instead.

func (*GetConsumerGroupsResponse) GetGroups 

func (x *GetConsumerGroupsResponse) GetGroups() map[string]*ConsumerGroup

func (*GetConsumerGroupsResponse) MarshalToSizedBufferVT 

func (m *GetConsumerGroupsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetConsumerGroupsResponse) MarshalToVT 

func (m *GetConsumerGroupsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetConsumerGroupsResponse) MarshalVT 

func (m *GetConsumerGroupsResponse) MarshalVT() (dAtA []byte, err error)

func (*GetConsumerGroupsResponse) ProtoMessage 

func (*GetConsumerGroupsResponse) ProtoMessage()

func (*GetConsumerGroupsResponse) ProtoReflect 

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

func (*GetConsumerGroupsResponse) Reset 

func (x *GetConsumerGroupsResponse) Reset()

func (*GetConsumerGroupsResponse) SizeVT 

func (m *GetConsumerGroupsResponse) SizeVT() (n int)

func (*GetConsumerGroupsResponse) String 

func (x *GetConsumerGroupsResponse) String() string

func (*GetConsumerGroupsResponse) UnmarshalVT 

func (m *GetConsumerGroupsResponse) UnmarshalVT(dAtA []byte) error

type GetMetaRequest 

type GetMetaRequest struct {
	// contains filtered or unexported fields
}

func (*GetMetaRequest) Descriptor deprecated 

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

Deprecated: Use GetMetaRequest.ProtoReflect.Descriptor instead.

func (*GetMetaRequest) MarshalToSizedBufferVT 

func (m *GetMetaRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetMetaRequest) MarshalToVT 

func (m *GetMetaRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetMetaRequest) MarshalVT 

func (m *GetMetaRequest) MarshalVT() (dAtA []byte, err error)

func (*GetMetaRequest) ProtoMessage 

func (*GetMetaRequest) ProtoMessage()

func (*GetMetaRequest) ProtoReflect 

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

func (*GetMetaRequest) Reset 

func (x *GetMetaRequest) Reset()

func (*GetMetaRequest) SizeVT 

func (m *GetMetaRequest) SizeVT() (n int)

func (*GetMetaRequest) String 

func (x *GetMetaRequest) String() string

func (*GetMetaRequest) UnmarshalVT 

func (m *GetMetaRequest) UnmarshalVT(dAtA []byte) error

type GetMetaResponse 

type GetMetaResponse struct {
	Topics         map[string]*Topic         `` /* 153-byte string literal not displayed */
	ConsumerGroups map[string]*ConsumerGroup `` /* 169-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetMetaResponse) Descriptor deprecated 

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

Deprecated: Use GetMetaResponse.ProtoReflect.Descriptor instead.

func (*GetMetaResponse) GetConsumerGroups 

func (x *GetMetaResponse) GetConsumerGroups() map[string]*ConsumerGroup

func (*GetMetaResponse) GetTopics 

func (x *GetMetaResponse) GetTopics() map[string]*Topic

func (*GetMetaResponse) MarshalToSizedBufferVT 

func (m *GetMetaResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetMetaResponse) MarshalToVT 

func (m *GetMetaResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetMetaResponse) MarshalVT 

func (m *GetMetaResponse) MarshalVT() (dAtA []byte, err error)

func (*GetMetaResponse) ProtoMessage 

func (*GetMetaResponse) ProtoMessage()

func (*GetMetaResponse) ProtoReflect 

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

func (*GetMetaResponse) Reset 

func (x *GetMetaResponse) Reset()

func (*GetMetaResponse) SizeVT 

func (m *GetMetaResponse) SizeVT() (n int)

func (*GetMetaResponse) String 

func (x *GetMetaResponse) String() string

func (*GetMetaResponse) UnmarshalVT 

func (m *GetMetaResponse) UnmarshalVT(dAtA []byte) error

type KeyVal 

type KeyVal struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Val []byte `protobuf:"bytes,2,opt,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyVal) Descriptor deprecated 

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

Deprecated: Use KeyVal.ProtoReflect.Descriptor instead.

func (*KeyVal) GetKey 

func (x *KeyVal) GetKey() []byte

func (*KeyVal) GetVal 

func (x *KeyVal) GetVal() []byte

func (*KeyVal) MarshalToSizedBufferVT 

func (m *KeyVal) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*KeyVal) MarshalToVT 

func (m *KeyVal) MarshalToVT(dAtA []byte) (int, error)

func (*KeyVal) MarshalVT 

func (m *KeyVal) MarshalVT() (dAtA []byte, err error)

func (*KeyVal) ProtoMessage 

func (*KeyVal) ProtoMessage()

func (*KeyVal) ProtoReflect 

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

func (*KeyVal) Reset 

func (x *KeyVal) Reset()

func (*KeyVal) SizeVT 

func (m *KeyVal) SizeVT() (n int)

func (*KeyVal) String 

func (x *KeyVal) String() string

func (*KeyVal) UnmarshalVT 

func (m *KeyVal) UnmarshalVT(dAtA []byte) error

type Message 

type Message struct {
	Key       []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Payload   []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Topic     string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition uint64 `protobuf:"varint,4,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset    uint64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
	RaftIndex uint64 `protobuf:"varint,6,opt,name=raftIndex,proto3" json:"raftIndex,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetKey 

func (x *Message) GetKey() []byte

func (*Message) GetOffset 

func (x *Message) GetOffset() uint64

func (*Message) GetPartition 

func (x *Message) GetPartition() uint64

func (*Message) GetPayload 

func (x *Message) GetPayload() []byte

func (*Message) GetRaftIndex 

func (x *Message) GetRaftIndex() uint64

func (*Message) GetTopic 

func (x *Message) GetTopic() string

func (*Message) MarshalToSizedBufferVT 

func (m *Message) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Message) MarshalToVT 

func (m *Message) MarshalToVT(dAtA []byte) (int, error)

func (*Message) MarshalVT 

func (m *Message) MarshalVT() (dAtA []byte, err error)

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) SizeVT 

func (m *Message) SizeVT() (n int)

func (*Message) String 

func (x *Message) String() string

func (*Message) UnmarshalVT 

func (m *Message) UnmarshalVT(dAtA []byte) error

type MessageServiceClient 

type MessageServiceClient interface {
	PublishMessages(ctx context.Context, in *PublishMessageRequest, opts ...grpc.CallOption) (*PublishMessageResponse, error)
	CreateConsumer(ctx context.Context, in *CreateConsumerRequest, opts ...grpc.CallOption) (*CreateConsumerResponse, error)
	CreateConsumerGroup(ctx context.Context, in *CreateConsumerGroupRequest, opts ...grpc.CallOption) (*CreateConsumerGroupResponse, error)
	GetConsumerGroups(ctx context.Context, in *GetConsumerGroupsRequest, opts ...grpc.CallOption) (*GetConsumerGroupsResponse, error)
	Consume(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (*ConsumeResponse, error)
	CreateTopic(ctx context.Context, in *CreateTopicRequest, opts ...grpc.CallOption) (*CreateTopicResponse, error)
	AckConsume(ctx context.Context, in *AckConsumeRequest, opts ...grpc.CallOption) (*AckConsumeResponse, error)
	GetMeta(ctx context.Context, in *GetMetaRequest, opts ...grpc.CallOption) (*GetMetaResponse, error)
}

MessageServiceClient is the client API for MessageService service.

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

func NewMessageServiceClient 

func NewMessageServiceClient(cc grpc.ClientConnInterface) MessageServiceClient

type MessageServiceServer 

type MessageServiceServer interface {
	PublishMessages(context.Context, *PublishMessageRequest) (*PublishMessageResponse, error)
	CreateConsumer(context.Context, *CreateConsumerRequest) (*CreateConsumerResponse, error)
	CreateConsumerGroup(context.Context, *CreateConsumerGroupRequest) (*CreateConsumerGroupResponse, error)
	GetConsumerGroups(context.Context, *GetConsumerGroupsRequest) (*GetConsumerGroupsResponse, error)
	Consume(context.Context, *ConsumeRequest) (*ConsumeResponse, error)
	CreateTopic(context.Context, *CreateTopicRequest) (*CreateTopicResponse, error)
	AckConsume(context.Context, *AckConsumeRequest) (*AckConsumeResponse, error)
	GetMeta(context.Context, *GetMetaRequest) (*GetMetaResponse, error)
	// contains filtered or unexported methods
}

MessageServiceServer is the server API for MessageService service. All implementations must embed UnimplementedMessageServiceServer for forward compatibility

type Messages 

type Messages struct {
	Messages []*Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*Messages) Descriptor deprecated 

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

Deprecated: Use Messages.ProtoReflect.Descriptor instead.

func (*Messages) GetMessages 

func (x *Messages) GetMessages() []*Message

func (*Messages) MarshalToSizedBufferVT 

func (m *Messages) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Messages) MarshalToVT 

func (m *Messages) MarshalToVT(dAtA []byte) (int, error)

func (*Messages) MarshalVT 

func (m *Messages) MarshalVT() (dAtA []byte, err error)

func (*Messages) ProtoMessage 

func (*Messages) ProtoMessage()

func (*Messages) ProtoReflect 

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

func (*Messages) Reset 

func (x *Messages) Reset()

func (*Messages) SizeVT 

func (m *Messages) SizeVT() (n int)

func (*Messages) String 

func (x *Messages) String() string

func (*Messages) UnmarshalVT 

func (m *Messages) UnmarshalVT(dAtA []byte) error

type Operation 

type Operation int32
const (
	Operation_PUBLISH               Operation = 0
	Operation_ACK                   Operation = 1
	Operation_CREATE_CONSUMER       Operation = 2
	Operation_CREATE_TOPIC          Operation = 3
	Operation_ADD_MEMBER            Operation = 4
	Operation_REMOVE_MEMBER         Operation = 5
	Operation_CREATE_CONSUMER_GROUP Operation = 6
)

func (Operation) Descriptor 

func (Operation) Descriptor() protoreflect.EnumDescriptor

func (Operation) Enum 

func (x Operation) Enum() *Operation

func (Operation) EnumDescriptor deprecated 

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

Deprecated: Use Operation.Descriptor instead.

func (Operation) Number 

func (x Operation) Number() protoreflect.EnumNumber

func (Operation) String 

func (x Operation) String() string

func (Operation) Type 

func (Operation) Type() protoreflect.EnumType

type Partition 

type Partition struct {
	Num    uint64 `protobuf:"varint,1,opt,name=num,proto3" json:"num,omitempty"`
	Topic  string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Offset uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*Partition) Descriptor deprecated 

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

Deprecated: Use Partition.ProtoReflect.Descriptor instead.

func (*Partition) GetNum 

func (x *Partition) GetNum() uint64

func (*Partition) GetOffset 

func (x *Partition) GetOffset() uint64

func (*Partition) GetTopic 

func (x *Partition) GetTopic() string

func (*Partition) MarshalToSizedBufferVT 

func (m *Partition) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Partition) MarshalToVT 

func (m *Partition) MarshalToVT(dAtA []byte) (int, error)

func (*Partition) MarshalVT 

func (m *Partition) MarshalVT() (dAtA []byte, err error)

func (*Partition) ProtoMessage 

func (*Partition) ProtoMessage()

func (*Partition) ProtoReflect 

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

func (*Partition) Reset 

func (x *Partition) Reset()

func (*Partition) SizeVT 

func (m *Partition) SizeVT() (n int)

func (*Partition) String 

func (x *Partition) String() string

func (*Partition) UnmarshalVT 

func (m *Partition) UnmarshalVT(dAtA []byte) error

type Publish 

type Publish struct {
	Topic     string    `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition uint64    `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	Messages  []*KeyVal `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*Publish) Descriptor deprecated 

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

Deprecated: Use Publish.ProtoReflect.Descriptor instead.

func (*Publish) GetMessages 

func (x *Publish) GetMessages() []*KeyVal

func (*Publish) GetPartition 

func (x *Publish) GetPartition() uint64

func (*Publish) GetTopic 

func (x *Publish) GetTopic() string

func (*Publish) MarshalToSizedBufferVT 

func (m *Publish) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Publish) MarshalToVT 

func (m *Publish) MarshalToVT(dAtA []byte) (int, error)

func (*Publish) MarshalVT 

func (m *Publish) MarshalVT() (dAtA []byte, err error)

func (*Publish) ProtoMessage 

func (*Publish) ProtoMessage()

func (*Publish) ProtoReflect 

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

func (*Publish) Reset 

func (x *Publish) Reset()

func (*Publish) SizeVT 

func (m *Publish) SizeVT() (n int)

func (*Publish) String 

func (x *Publish) String() string

func (*Publish) UnmarshalVT 

func (m *Publish) UnmarshalVT(dAtA []byte) error

type PublishMessageRequest 

type PublishMessageRequest struct {
	Topic     string    `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition uint64    `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	Messages  []*KeyVal `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishMessageRequest) Descriptor deprecated 

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

Deprecated: Use PublishMessageRequest.ProtoReflect.Descriptor instead.

func (*PublishMessageRequest) GetMessages 

func (x *PublishMessageRequest) GetMessages() []*KeyVal

func (*PublishMessageRequest) GetPartition 

func (x *PublishMessageRequest) GetPartition() uint64

func (*PublishMessageRequest) GetTopic 

func (x *PublishMessageRequest) GetTopic() string

func (*PublishMessageRequest) MarshalToSizedBufferVT 

func (m *PublishMessageRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PublishMessageRequest) MarshalToVT 

func (m *PublishMessageRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PublishMessageRequest) MarshalVT 

func (m *PublishMessageRequest) MarshalVT() (dAtA []byte, err error)

func (*PublishMessageRequest) ProtoMessage 

func (*PublishMessageRequest) ProtoMessage()

func (*PublishMessageRequest) ProtoReflect 

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

func (*PublishMessageRequest) Reset 

func (x *PublishMessageRequest) Reset()

func (*PublishMessageRequest) SizeVT 

func (m *PublishMessageRequest) SizeVT() (n int)

func (*PublishMessageRequest) String 

func (x *PublishMessageRequest) String() string

func (*PublishMessageRequest) UnmarshalVT 

func (m *PublishMessageRequest) UnmarshalVT(dAtA []byte) error

type PublishMessageResponse 

type PublishMessageResponse struct {
	Messages  []*Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	LastIndex uint64     `protobuf:"varint,2,opt,name=lastIndex,proto3" json:"lastIndex,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishMessageResponse) Descriptor deprecated 

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

Deprecated: Use PublishMessageResponse.ProtoReflect.Descriptor instead.

func (*PublishMessageResponse) GetLastIndex 

func (x *PublishMessageResponse) GetLastIndex() uint64

func (*PublishMessageResponse) GetMessages 

func (x *PublishMessageResponse) GetMessages() []*Message

func (*PublishMessageResponse) MarshalToSizedBufferVT 

func (m *PublishMessageResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PublishMessageResponse) MarshalToVT 

func (m *PublishMessageResponse) MarshalToVT(dAtA []byte) (int, error)

func (*PublishMessageResponse) MarshalVT 

func (m *PublishMessageResponse) MarshalVT() (dAtA []byte, err error)

func (*PublishMessageResponse) ProtoMessage 

func (*PublishMessageResponse) ProtoMessage()

func (*PublishMessageResponse) ProtoReflect 

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

func (*PublishMessageResponse) Reset 

func (x *PublishMessageResponse) Reset()

func (*PublishMessageResponse) SizeVT 

func (m *PublishMessageResponse) SizeVT() (n int)

func (*PublishMessageResponse) String 

func (x *PublishMessageResponse) String() string

func (*PublishMessageResponse) UnmarshalVT 

func (m *PublishMessageResponse) UnmarshalVT(dAtA []byte) error

type PublishResult 

type PublishResult struct {
	Messages []*Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishResult) Descriptor deprecated 

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

Deprecated: Use PublishResult.ProtoReflect.Descriptor instead.

func (*PublishResult) GetMessages 

func (x *PublishResult) GetMessages() []*Message

func (*PublishResult) MarshalToSizedBufferVT 

func (m *PublishResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PublishResult) MarshalToVT 

func (m *PublishResult) MarshalToVT(dAtA []byte) (int, error)

func (*PublishResult) MarshalVT 

func (m *PublishResult) MarshalVT() (dAtA []byte, err error)

func (*PublishResult) ProtoMessage 

func (*PublishResult) ProtoMessage()

func (*PublishResult) ProtoReflect 

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

func (*PublishResult) Reset 

func (x *PublishResult) Reset()

func (*PublishResult) SizeVT 

func (m *PublishResult) SizeVT() (n int)

func (*PublishResult) String 

func (x *PublishResult) String() string

func (*PublishResult) UnmarshalVT 

func (m *PublishResult) UnmarshalVT(dAtA []byte) error

type RemoveMember 

type RemoveMember struct {
	NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveMember) Descriptor deprecated 

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

Deprecated: Use RemoveMember.ProtoReflect.Descriptor instead.

func (*RemoveMember) GetNodeId 

func (x *RemoveMember) GetNodeId() string

func (*RemoveMember) MarshalToSizedBufferVT 

func (m *RemoveMember) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RemoveMember) MarshalToVT 

func (m *RemoveMember) MarshalToVT(dAtA []byte) (int, error)

func (*RemoveMember) MarshalVT 

func (m *RemoveMember) MarshalVT() (dAtA []byte, err error)

func (*RemoveMember) ProtoMessage 

func (*RemoveMember) ProtoMessage()

func (*RemoveMember) ProtoReflect 

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

func (*RemoveMember) Reset 

func (x *RemoveMember) Reset()

func (*RemoveMember) SizeVT 

func (m *RemoveMember) SizeVT() (n int)

func (*RemoveMember) String 

func (x *RemoveMember) String() string

func (*RemoveMember) UnmarshalVT 

func (m *RemoveMember) UnmarshalVT(dAtA []byte) error

type RemoveMemberResult 

type RemoveMemberResult struct {
	// contains filtered or unexported fields
}

func (*RemoveMemberResult) Descriptor deprecated 

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

Deprecated: Use RemoveMemberResult.ProtoReflect.Descriptor instead.

func (*RemoveMemberResult) MarshalToSizedBufferVT 

func (m *RemoveMemberResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RemoveMemberResult) MarshalToVT 

func (m *RemoveMemberResult) MarshalToVT(dAtA []byte) (int, error)

func (*RemoveMemberResult) MarshalVT 

func (m *RemoveMemberResult) MarshalVT() (dAtA []byte, err error)

func (*RemoveMemberResult) ProtoMessage 

func (*RemoveMemberResult) ProtoMessage()

func (*RemoveMemberResult) ProtoReflect 

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

func (*RemoveMemberResult) Reset 

func (x *RemoveMemberResult) Reset()

func (*RemoveMemberResult) SizeVT 

func (m *RemoveMemberResult) SizeVT() (n int)

func (*RemoveMemberResult) String 

func (x *RemoveMemberResult) String() string

func (*RemoveMemberResult) UnmarshalVT 

func (m *RemoveMemberResult) UnmarshalVT(dAtA []byte) error

type ScaleTopicRequest 

type ScaleTopicRequest struct {
	Topic      string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partitions uint64 `protobuf:"varint,2,opt,name=partitions,proto3" json:"partitions,omitempty"`
	// contains filtered or unexported fields
}

func (*ScaleTopicRequest) Descriptor deprecated 

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

Deprecated: Use ScaleTopicRequest.ProtoReflect.Descriptor instead.

func (*ScaleTopicRequest) GetPartitions 

func (x *ScaleTopicRequest) GetPartitions() uint64

func (*ScaleTopicRequest) GetTopic 

func (x *ScaleTopicRequest) GetTopic() string

func (*ScaleTopicRequest) MarshalToSizedBufferVT 

func (m *ScaleTopicRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ScaleTopicRequest) MarshalToVT 

func (m *ScaleTopicRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ScaleTopicRequest) MarshalVT 

func (m *ScaleTopicRequest) MarshalVT() (dAtA []byte, err error)

func (*ScaleTopicRequest) ProtoMessage 

func (*ScaleTopicRequest) ProtoMessage()

func (*ScaleTopicRequest) ProtoReflect 

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

func (*ScaleTopicRequest) Reset 

func (x *ScaleTopicRequest) Reset()

func (*ScaleTopicRequest) SizeVT 

func (m *ScaleTopicRequest) SizeVT() (n int)

func (*ScaleTopicRequest) String 

func (x *ScaleTopicRequest) String() string

func (*ScaleTopicRequest) UnmarshalVT 

func (m *ScaleTopicRequest) UnmarshalVT(dAtA []byte) error

type ScaleTopicResponse 

type ScaleTopicResponse struct {
	LastIndex uint64 `protobuf:"varint,1,opt,name=lastIndex,proto3" json:"lastIndex,omitempty"`
	// contains filtered or unexported fields
}

func (*ScaleTopicResponse) Descriptor deprecated 

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

Deprecated: Use ScaleTopicResponse.ProtoReflect.Descriptor instead.

func (*ScaleTopicResponse) GetLastIndex 

func (x *ScaleTopicResponse) GetLastIndex() uint64

func (*ScaleTopicResponse) MarshalToSizedBufferVT 

func (m *ScaleTopicResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ScaleTopicResponse) MarshalToVT 

func (m *ScaleTopicResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ScaleTopicResponse) MarshalVT 

func (m *ScaleTopicResponse) MarshalVT() (dAtA []byte, err error)

func (*ScaleTopicResponse) ProtoMessage 

func (*ScaleTopicResponse) ProtoMessage()

func (*ScaleTopicResponse) ProtoReflect 

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

func (*ScaleTopicResponse) Reset 

func (x *ScaleTopicResponse) Reset()

func (*ScaleTopicResponse) SizeVT 

func (m *ScaleTopicResponse) SizeVT() (n int)

func (*ScaleTopicResponse) String 

func (x *ScaleTopicResponse) String() string

func (*ScaleTopicResponse) UnmarshalVT 

func (m *ScaleTopicResponse) UnmarshalVT(dAtA []byte) error

type Snapshot 

type Snapshot struct {
	// contains filtered or unexported fields
}

func (*Snapshot) Descriptor deprecated 

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

Deprecated: Use Snapshot.ProtoReflect.Descriptor instead.

func (*Snapshot) MarshalToSizedBufferVT 

func (m *Snapshot) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Snapshot) MarshalToVT 

func (m *Snapshot) MarshalToVT(dAtA []byte) (int, error)

func (*Snapshot) MarshalVT 

func (m *Snapshot) MarshalVT() (dAtA []byte, err error)

func (*Snapshot) ProtoMessage 

func (*Snapshot) ProtoMessage()

func (*Snapshot) ProtoReflect 

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

func (*Snapshot) Reset 

func (x *Snapshot) Reset()

func (*Snapshot) SizeVT 

func (m *Snapshot) SizeVT() (n int)

func (*Snapshot) String 

func (x *Snapshot) String() string

func (*Snapshot) UnmarshalVT 

func (m *Snapshot) UnmarshalVT(dAtA []byte) error

type Topic 

type Topic struct {
	Name       string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Partitions map[uint64]*Partition `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Topic) Descriptor deprecated 

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetName 

func (x *Topic) GetName() string

func (*Topic) GetPartitions 

func (x *Topic) GetPartitions() map[uint64]*Partition

func (*Topic) MarshalToSizedBufferVT 

func (m *Topic) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Topic) MarshalToVT 

func (m *Topic) MarshalToVT(dAtA []byte) (int, error)

func (*Topic) MarshalVT 

func (m *Topic) MarshalVT() (dAtA []byte, err error)

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect 

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

func (*Topic) Reset 

func (x *Topic) Reset()

func (*Topic) SizeVT 

func (m *Topic) SizeVT() (n int)

func (*Topic) String 

func (x *Topic) String() string

func (*Topic) UnmarshalVT 

func (m *Topic) UnmarshalVT(dAtA []byte) error

type UnimplementedMessageServiceServer 

type UnimplementedMessageServiceServer struct {
}

UnimplementedMessageServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMessageServiceServer) AckConsume 

func (UnimplementedMessageServiceServer) AckConsume(context.Context, *AckConsumeRequest) (*AckConsumeResponse, error)

func (UnimplementedMessageServiceServer) Consume 

func (UnimplementedMessageServiceServer) Consume(context.Context, *ConsumeRequest) (*ConsumeResponse, error)

func (UnimplementedMessageServiceServer) CreateConsumer 

func (UnimplementedMessageServiceServer) CreateConsumer(context.Context, *CreateConsumerRequest) (*CreateConsumerResponse, error)

func (UnimplementedMessageServiceServer) CreateConsumerGroup 

func (UnimplementedMessageServiceServer) CreateConsumerGroup(context.Context, *CreateConsumerGroupRequest) (*CreateConsumerGroupResponse, error)

func (UnimplementedMessageServiceServer) CreateTopic 

func (UnimplementedMessageServiceServer) CreateTopic(context.Context, *CreateTopicRequest) (*CreateTopicResponse, error)

func (UnimplementedMessageServiceServer) GetConsumerGroups 

func (UnimplementedMessageServiceServer) GetConsumerGroups(context.Context, *GetConsumerGroupsRequest) (*GetConsumerGroupsResponse, error)

func (UnimplementedMessageServiceServer) GetMeta 

func (UnimplementedMessageServiceServer) GetMeta(context.Context, *GetMetaRequest) (*GetMetaResponse, error)

func (UnimplementedMessageServiceServer) PublishMessages 

func (UnimplementedMessageServiceServer) PublishMessages(context.Context, *PublishMessageRequest) (*PublishMessageResponse, error)

type UnsafeMessageServiceServer 

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

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

type WriteOperation 

type WriteOperation struct {

	// Types that are assignable to Operation:
	//
	//	*WriteOperation_Publish
	//	*WriteOperation_Ack
	//	*WriteOperation_CreateConsumer
	//	*WriteOperation_CreateTopic
	//	*WriteOperation_AddMember
	//	*WriteOperation_RemoveMember
	//	*WriteOperation_CreateConsumerGroup
	Operation isWriteOperation_Operation `protobuf_oneof:"operation"`
	Code      Operation                  `protobuf:"varint,8,opt,name=code,proto3,enum=message.Operation" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteOperation) Descriptor deprecated 

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

Deprecated: Use WriteOperation.ProtoReflect.Descriptor instead.

func (*WriteOperation) GetAck 

func (x *WriteOperation) GetAck() *Ack

func (*WriteOperation) GetAddMember 

func (x *WriteOperation) GetAddMember() *AddMember

func (*WriteOperation) GetCode 

func (x *WriteOperation) GetCode() Operation

func (*WriteOperation) GetCreateConsumer 

func (x *WriteOperation) GetCreateConsumer() *CreateConsumer

func (*WriteOperation) GetCreateConsumerGroup 

func (x *WriteOperation) GetCreateConsumerGroup() *CreateConsumerGroup

func (*WriteOperation) GetCreateTopic 

func (x *WriteOperation) GetCreateTopic() *CreateTopic

func (*WriteOperation) GetOperation 

func (m *WriteOperation) GetOperation() isWriteOperation_Operation

func (*WriteOperation) GetPublish 

func (x *WriteOperation) GetPublish() *Publish

func (*WriteOperation) GetRemoveMember 

func (x *WriteOperation) GetRemoveMember() *RemoveMember

func (*WriteOperation) MarshalToSizedBufferVT 

func (m *WriteOperation) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteOperation) MarshalToVT 

func (m *WriteOperation) MarshalToVT(dAtA []byte) (int, error)

func (*WriteOperation) MarshalVT 

func (m *WriteOperation) MarshalVT() (dAtA []byte, err error)

func (*WriteOperation) ProtoMessage 

func (*WriteOperation) ProtoMessage()

func (*WriteOperation) ProtoReflect 

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

func (*WriteOperation) Reset 

func (x *WriteOperation) Reset()

func (*WriteOperation) SizeVT 

func (m *WriteOperation) SizeVT() (n int)

func (*WriteOperation) String 

func (x *WriteOperation) String() string

func (*WriteOperation) UnmarshalVT 

func (m *WriteOperation) UnmarshalVT(dAtA []byte) error

type WriteOperation_Ack 

type WriteOperation_Ack struct {
	Ack *Ack `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

func (*WriteOperation_Ack) MarshalToSizedBufferVT 

func (m *WriteOperation_Ack) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteOperation_Ack) MarshalToVT 

func (m *WriteOperation_Ack) MarshalToVT(dAtA []byte) (int, error)

func (*WriteOperation_Ack) SizeVT 

func (m *WriteOperation_Ack) SizeVT() (n int)

type WriteOperation_AddMember 

type WriteOperation_AddMember struct {
	AddMember *AddMember `protobuf:"bytes,5,opt,name=addMember,proto3,oneof"`
}

func (*WriteOperation_AddMember) MarshalToSizedBufferVT 

func (m *WriteOperation_AddMember) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteOperation_AddMember) MarshalToVT 

func (m *WriteOperation_AddMember) MarshalToVT(dAtA []byte) (int, error)

func (*WriteOperation_AddMember) SizeVT 

func (m *WriteOperation_AddMember) SizeVT() (n int)

type WriteOperation_CreateConsumer 

type WriteOperation_CreateConsumer struct {
	CreateConsumer *CreateConsumer `protobuf:"bytes,3,opt,name=createConsumer,proto3,oneof"`
}

func (*WriteOperation_CreateConsumer) MarshalToSizedBufferVT 

func (m *WriteOperation_CreateConsumer) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteOperation_CreateConsumer) MarshalToVT 

func (m *WriteOperation_CreateConsumer) MarshalToVT(dAtA []byte) (int, error)

func (*WriteOperation_CreateConsumer) SizeVT 

func (m *WriteOperation_CreateConsumer) SizeVT() (n int)

type WriteOperation_CreateConsumerGroup 

type WriteOperation_CreateConsumerGroup struct {
	CreateConsumerGroup *CreateConsumerGroup `protobuf:"bytes,7,opt,name=createConsumerGroup,proto3,oneof"`
}

func (*WriteOperation_CreateConsumerGroup) MarshalToSizedBufferVT 

func (m *WriteOperation_CreateConsumerGroup) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteOperation_CreateConsumerGroup) MarshalToVT 

func (m *WriteOperation_CreateConsumerGroup) MarshalToVT(dAtA []byte) (int, error)

func (*WriteOperation_CreateConsumerGroup) SizeVT 

func (m *WriteOperation_CreateConsumerGroup) SizeVT() (n int)

type WriteOperation_CreateTopic 

type WriteOperation_CreateTopic struct {
	CreateTopic *CreateTopic `protobuf:"bytes,4,opt,name=createTopic,proto3,oneof"`
}

func (*WriteOperation_CreateTopic) MarshalToSizedBufferVT 

func (m *WriteOperation_CreateTopic) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteOperation_CreateTopic) MarshalToVT 

func (m *WriteOperation_CreateTopic) MarshalToVT(dAtA []byte) (int, error)

func (*WriteOperation_CreateTopic) SizeVT 

func (m *WriteOperation_CreateTopic) SizeVT() (n int)

type WriteOperation_Publish 

type WriteOperation_Publish struct {
	Publish *Publish `protobuf:"bytes,1,opt,name=publish,proto3,oneof"`
}

func (*WriteOperation_Publish) MarshalToSizedBufferVT 

func (m *WriteOperation_Publish) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteOperation_Publish) MarshalToVT 

func (m *WriteOperation_Publish) MarshalToVT(dAtA []byte) (int, error)

func (*WriteOperation_Publish) SizeVT 

func (m *WriteOperation_Publish) SizeVT() (n int)

type WriteOperation_RemoveMember 

type WriteOperation_RemoveMember struct {
	RemoveMember *RemoveMember `protobuf:"bytes,6,opt,name=removeMember,proto3,oneof"`
}

func (*WriteOperation_RemoveMember) MarshalToSizedBufferVT 

func (m *WriteOperation_RemoveMember) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteOperation_RemoveMember) MarshalToVT 

func (m *WriteOperation_RemoveMember) MarshalToVT(dAtA []byte) (int, error)

func (*WriteOperation_RemoveMember) SizeVT 

func (m *WriteOperation_RemoveMember) SizeVT() (n int)

type WriteResult 

type WriteResult struct {

	// Types that are assignable to Result:
	//
	//	*WriteResult_PublishResult
	//	*WriteResult_AckResult
	//	*WriteResult_CreateConsumerResult
	//	*WriteResult_CreateTopicResult
	//	*WriteResult_AddMemberResult
	//	*WriteResult_RemoveMemberResult
	//	*WriteResult_CreateConsumerGroupResult
	Result isWriteResult_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*WriteResult) Descriptor deprecated 

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

Deprecated: Use WriteResult.ProtoReflect.Descriptor instead.

func (*WriteResult) GetAckResult 

func (x *WriteResult) GetAckResult() *AckResult

func (*WriteResult) GetAddMemberResult 

func (x *WriteResult) GetAddMemberResult() *AddMemberResult

func (*WriteResult) GetCreateConsumerGroupResult 

func (x *WriteResult) GetCreateConsumerGroupResult() *CreateConsumerGroupResult

func (*WriteResult) GetCreateConsumerResult 

func (x *WriteResult) GetCreateConsumerResult() *CreateConsumerResult

func (*WriteResult) GetCreateTopicResult 

func (x *WriteResult) GetCreateTopicResult() *CreateTopicResult

func (*WriteResult) GetPublishResult 

func (x *WriteResult) GetPublishResult() *PublishResult

func (*WriteResult) GetRemoveMemberResult 

func (x *WriteResult) GetRemoveMemberResult() *RemoveMemberResult

func (*WriteResult) GetResult 

func (m *WriteResult) GetResult() isWriteResult_Result

func (*WriteResult) MarshalToSizedBufferVT 

func (m *WriteResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteResult) MarshalToVT 

func (m *WriteResult) MarshalToVT(dAtA []byte) (int, error)

func (*WriteResult) MarshalVT 

func (m *WriteResult) MarshalVT() (dAtA []byte, err error)

func (*WriteResult) ProtoMessage 

func (*WriteResult) ProtoMessage()

func (*WriteResult) ProtoReflect 

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

func (*WriteResult) Reset 

func (x *WriteResult) Reset()

func (*WriteResult) SizeVT 

func (m *WriteResult) SizeVT() (n int)

func (*WriteResult) String 

func (x *WriteResult) String() string

func (*WriteResult) UnmarshalVT 

func (m *WriteResult) UnmarshalVT(dAtA []byte) error

type WriteResult_AckResult 

type WriteResult_AckResult struct {
	AckResult *AckResult `protobuf:"bytes,2,opt,name=ackResult,proto3,oneof"`
}

func (*WriteResult_AckResult) MarshalToSizedBufferVT 

func (m *WriteResult_AckResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteResult_AckResult) MarshalToVT 

func (m *WriteResult_AckResult) MarshalToVT(dAtA []byte) (int, error)

func (*WriteResult_AckResult) SizeVT 

func (m *WriteResult_AckResult) SizeVT() (n int)

type WriteResult_AddMemberResult 

type WriteResult_AddMemberResult struct {
	AddMemberResult *AddMemberResult `protobuf:"bytes,5,opt,name=addMemberResult,proto3,oneof"`
}

func (*WriteResult_AddMemberResult) MarshalToSizedBufferVT 

func (m *WriteResult_AddMemberResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteResult_AddMemberResult) MarshalToVT 

func (m *WriteResult_AddMemberResult) MarshalToVT(dAtA []byte) (int, error)

func (*WriteResult_AddMemberResult) SizeVT 

func (m *WriteResult_AddMemberResult) SizeVT() (n int)

type WriteResult_CreateConsumerGroupResult 

type WriteResult_CreateConsumerGroupResult struct {
	CreateConsumerGroupResult *CreateConsumerGroupResult `protobuf:"bytes,7,opt,name=createConsumerGroupResult,proto3,oneof"`
}

func (*WriteResult_CreateConsumerGroupResult) MarshalToSizedBufferVT 

func (m *WriteResult_CreateConsumerGroupResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteResult_CreateConsumerGroupResult) MarshalToVT 

func (m *WriteResult_CreateConsumerGroupResult) MarshalToVT(dAtA []byte) (int, error)

func (*WriteResult_CreateConsumerGroupResult) SizeVT 

func (m *WriteResult_CreateConsumerGroupResult) SizeVT() (n int)

type WriteResult_CreateConsumerResult 

type WriteResult_CreateConsumerResult struct {
	CreateConsumerResult *CreateConsumerResult `protobuf:"bytes,3,opt,name=createConsumerResult,proto3,oneof"`
}

func (*WriteResult_CreateConsumerResult) MarshalToSizedBufferVT 

func (m *WriteResult_CreateConsumerResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteResult_CreateConsumerResult) MarshalToVT 

func (m *WriteResult_CreateConsumerResult) MarshalToVT(dAtA []byte) (int, error)

func (*WriteResult_CreateConsumerResult) SizeVT 

func (m *WriteResult_CreateConsumerResult) SizeVT() (n int)

type WriteResult_CreateTopicResult 

type WriteResult_CreateTopicResult struct {
	CreateTopicResult *CreateTopicResult `protobuf:"bytes,4,opt,name=createTopicResult,proto3,oneof"`
}

func (*WriteResult_CreateTopicResult) MarshalToSizedBufferVT 

func (m *WriteResult_CreateTopicResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteResult_CreateTopicResult) MarshalToVT 

func (m *WriteResult_CreateTopicResult) MarshalToVT(dAtA []byte) (int, error)

func (*WriteResult_CreateTopicResult) SizeVT 

func (m *WriteResult_CreateTopicResult) SizeVT() (n int)

type WriteResult_PublishResult 

type WriteResult_PublishResult struct {
	PublishResult *PublishResult `protobuf:"bytes,1,opt,name=publishResult,proto3,oneof"`
}

func (*WriteResult_PublishResult) MarshalToSizedBufferVT 

func (m *WriteResult_PublishResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteResult_PublishResult) MarshalToVT 

func (m *WriteResult_PublishResult) MarshalToVT(dAtA []byte) (int, error)

func (*WriteResult_PublishResult) SizeVT 

func (m *WriteResult_PublishResult) SizeVT() (n int)

type WriteResult_RemoveMemberResult 

type WriteResult_RemoveMemberResult struct {
	RemoveMemberResult *RemoveMemberResult `protobuf:"bytes,6,opt,name=removeMemberResult,proto3,oneof"`
}

func (*WriteResult_RemoveMemberResult) MarshalToSizedBufferVT 

func (m *WriteResult_RemoveMemberResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*WriteResult_RemoveMemberResult) MarshalToVT 

func (m *WriteResult_RemoveMemberResult) MarshalToVT(dAtA []byte) (int, error)

func (*WriteResult_RemoveMemberResult) SizeVT 

func (m *WriteResult_RemoveMemberResult) SizeVT() (n int)

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.