mq_pb

package
v0.0.0-...-d8bde9b Latest Latest
Warning

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

 Go to latest Published: Jun 3, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SeaweedMessaging_FindBrokerLeader_FullMethodName           = "/messaging_pb.SeaweedMessaging/FindBrokerLeader"
	SeaweedMessaging_PublisherToPubBalancer_FullMethodName     = "/messaging_pb.SeaweedMessaging/PublisherToPubBalancer"
	SeaweedMessaging_BalanceTopics_FullMethodName              = "/messaging_pb.SeaweedMessaging/BalanceTopics"
	SeaweedMessaging_ListTopics_FullMethodName                 = "/messaging_pb.SeaweedMessaging/ListTopics"
	SeaweedMessaging_ConfigureTopic_FullMethodName             = "/messaging_pb.SeaweedMessaging/ConfigureTopic"
	SeaweedMessaging_LookupTopicBrokers_FullMethodName         = "/messaging_pb.SeaweedMessaging/LookupTopicBrokers"
	SeaweedMessaging_AssignTopicPartitions_FullMethodName      = "/messaging_pb.SeaweedMessaging/AssignTopicPartitions"
	SeaweedMessaging_ClosePublishers_FullMethodName            = "/messaging_pb.SeaweedMessaging/ClosePublishers"
	SeaweedMessaging_CloseSubscribers_FullMethodName           = "/messaging_pb.SeaweedMessaging/CloseSubscribers"
	SeaweedMessaging_SubscriberToSubCoordinator_FullMethodName = "/messaging_pb.SeaweedMessaging/SubscriberToSubCoordinator"
	SeaweedMessaging_PublishMessage_FullMethodName             = "/messaging_pb.SeaweedMessaging/PublishMessage"
	SeaweedMessaging_SubscribeMessage_FullMethodName           = "/messaging_pb.SeaweedMessaging/SubscribeMessage"
	SeaweedMessaging_PublishFollowMe_FullMethodName            = "/messaging_pb.SeaweedMessaging/PublishFollowMe"
)

Variables

View Source 
var (
	PartitionOffsetStartType_name = map[int32]string{
		0: "EARLIEST",
		1: "EARLIEST_IN_MEMORY",
		2: "LATEST",
	}
	PartitionOffsetStartType_value = map[string]int32{
		"EARLIEST":           0,
		"EARLIEST_IN_MEMORY": 1,
		"LATEST":             2,
	}
)

Enum value maps for PartitionOffsetStartType.

View Source 
var File_mq_proto protoreflect.FileDescriptor
View Source 
var SeaweedMessaging_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "messaging_pb.SeaweedMessaging",
	HandlerType: (*SeaweedMessagingServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FindBrokerLeader",
			Handler:    _SeaweedMessaging_FindBrokerLeader_Handler,
		},
		{
			MethodName: "BalanceTopics",
			Handler:    _SeaweedMessaging_BalanceTopics_Handler,
		},
		{
			MethodName: "ListTopics",
			Handler:    _SeaweedMessaging_ListTopics_Handler,
		},
		{
			MethodName: "ConfigureTopic",
			Handler:    _SeaweedMessaging_ConfigureTopic_Handler,
		},
		{
			MethodName: "LookupTopicBrokers",
			Handler:    _SeaweedMessaging_LookupTopicBrokers_Handler,
		},
		{
			MethodName: "AssignTopicPartitions",
			Handler:    _SeaweedMessaging_AssignTopicPartitions_Handler,
		},
		{
			MethodName: "ClosePublishers",
			Handler:    _SeaweedMessaging_ClosePublishers_Handler,
		},
		{
			MethodName: "CloseSubscribers",
			Handler:    _SeaweedMessaging_CloseSubscribers_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PublisherToPubBalancer",
			Handler:       _SeaweedMessaging_PublisherToPubBalancer_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SubscriberToSubCoordinator",
			Handler:       _SeaweedMessaging_SubscriberToSubCoordinator_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "PublishMessage",
			Handler:       _SeaweedMessaging_PublishMessage_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SubscribeMessage",
			Handler:       _SeaweedMessaging_SubscribeMessage_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "PublishFollowMe",
			Handler:       _SeaweedMessaging_PublishFollowMe_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "mq.proto",
}

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

Functions

func RegisterSeaweedMessagingServer 

func RegisterSeaweedMessagingServer(s grpc.ServiceRegistrar, srv SeaweedMessagingServer)

Types

type AssignTopicPartitionsRequest 

type AssignTopicPartitionsRequest struct {
	Topic                      *Topic                       `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	BrokerPartitionAssignments []*BrokerPartitionAssignment `` /* 141-byte string literal not displayed */
	IsLeader                   bool                         `protobuf:"varint,3,opt,name=is_leader,json=isLeader,proto3" json:"is_leader,omitempty"`
	IsDraining                 bool                         `protobuf:"varint,4,opt,name=is_draining,json=isDraining,proto3" json:"is_draining,omitempty"`
	// contains filtered or unexported fields
}

func (*AssignTopicPartitionsRequest) Descriptor deprecated 

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

Deprecated: Use AssignTopicPartitionsRequest.ProtoReflect.Descriptor instead.

func (*AssignTopicPartitionsRequest) GetBrokerPartitionAssignments 

func (x *AssignTopicPartitionsRequest) GetBrokerPartitionAssignments() []*BrokerPartitionAssignment

func (*AssignTopicPartitionsRequest) GetIsDraining 

func (x *AssignTopicPartitionsRequest) GetIsDraining() bool

func (*AssignTopicPartitionsRequest) GetIsLeader 

func (x *AssignTopicPartitionsRequest) GetIsLeader() bool

func (*AssignTopicPartitionsRequest) GetTopic 

func (x *AssignTopicPartitionsRequest) GetTopic() *Topic

func (*AssignTopicPartitionsRequest) ProtoMessage 

func (*AssignTopicPartitionsRequest) ProtoMessage()

func (*AssignTopicPartitionsRequest) ProtoReflect 

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

func (*AssignTopicPartitionsRequest) Reset 

func (x *AssignTopicPartitionsRequest) Reset()

func (*AssignTopicPartitionsRequest) String 

func (x *AssignTopicPartitionsRequest) String() string

type AssignTopicPartitionsResponse 

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

func (*AssignTopicPartitionsResponse) Descriptor deprecated 

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

Deprecated: Use AssignTopicPartitionsResponse.ProtoReflect.Descriptor instead.

func (*AssignTopicPartitionsResponse) ProtoMessage 

func (*AssignTopicPartitionsResponse) ProtoMessage()

func (*AssignTopicPartitionsResponse) ProtoReflect 

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

func (*AssignTopicPartitionsResponse) Reset 

func (x *AssignTopicPartitionsResponse) Reset()

func (*AssignTopicPartitionsResponse) String 

func (x *AssignTopicPartitionsResponse) String() string

type BalanceTopicsRequest 

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

func (*BalanceTopicsRequest) Descriptor deprecated 

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

Deprecated: Use BalanceTopicsRequest.ProtoReflect.Descriptor instead.

func (*BalanceTopicsRequest) ProtoMessage 

func (*BalanceTopicsRequest) ProtoMessage()

func (*BalanceTopicsRequest) ProtoReflect 

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

func (*BalanceTopicsRequest) Reset 

func (x *BalanceTopicsRequest) Reset()

func (*BalanceTopicsRequest) String 

func (x *BalanceTopicsRequest) String() string

type BalanceTopicsResponse 

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

func (*BalanceTopicsResponse) Descriptor deprecated 

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

Deprecated: Use BalanceTopicsResponse.ProtoReflect.Descriptor instead.

func (*BalanceTopicsResponse) ProtoMessage 

func (*BalanceTopicsResponse) ProtoMessage()

func (*BalanceTopicsResponse) ProtoReflect 

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

func (*BalanceTopicsResponse) Reset 

func (x *BalanceTopicsResponse) Reset()

func (*BalanceTopicsResponse) String 

func (x *BalanceTopicsResponse) String() string

type BrokerPartitionAssignment 

type BrokerPartitionAssignment struct {
	Partition       *Partition `protobuf:"bytes,1,opt,name=partition,proto3" json:"partition,omitempty"`
	LeaderBroker    string     `protobuf:"bytes,2,opt,name=leader_broker,json=leaderBroker,proto3" json:"leader_broker,omitempty"`
	FollowerBrokers []string   `protobuf:"bytes,3,rep,name=follower_brokers,json=followerBrokers,proto3" json:"follower_brokers,omitempty"`
	// contains filtered or unexported fields
}

func (*BrokerPartitionAssignment) Descriptor deprecated 

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

Deprecated: Use BrokerPartitionAssignment.ProtoReflect.Descriptor instead.

func (*BrokerPartitionAssignment) GetFollowerBrokers 

func (x *BrokerPartitionAssignment) GetFollowerBrokers() []string

func (*BrokerPartitionAssignment) GetLeaderBroker 

func (x *BrokerPartitionAssignment) GetLeaderBroker() string

func (*BrokerPartitionAssignment) GetPartition 

func (x *BrokerPartitionAssignment) GetPartition() *Partition

func (*BrokerPartitionAssignment) ProtoMessage 

func (*BrokerPartitionAssignment) ProtoMessage()

func (*BrokerPartitionAssignment) ProtoReflect 

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

func (*BrokerPartitionAssignment) Reset 

func (x *BrokerPartitionAssignment) Reset()

func (*BrokerPartitionAssignment) String 

func (x *BrokerPartitionAssignment) String() string

type BrokerStats 

type BrokerStats struct {
	CpuUsagePercent int32                           `protobuf:"varint,1,opt,name=cpu_usage_percent,json=cpuUsagePercent,proto3" json:"cpu_usage_percent,omitempty"`
	Stats           map[string]*TopicPartitionStats `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

////////////////////////////////////////////////

func (*BrokerStats) Descriptor deprecated 

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

Deprecated: Use BrokerStats.ProtoReflect.Descriptor instead.

func (*BrokerStats) GetCpuUsagePercent 

func (x *BrokerStats) GetCpuUsagePercent() int32

func (*BrokerStats) GetStats 

func (x *BrokerStats) GetStats() map[string]*TopicPartitionStats

func (*BrokerStats) ProtoMessage 

func (*BrokerStats) ProtoMessage()

func (*BrokerStats) ProtoReflect 

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

func (*BrokerStats) Reset 

func (x *BrokerStats) Reset()

func (*BrokerStats) String 

func (x *BrokerStats) String() string

type ClosePublishersRequest 

type ClosePublishersRequest struct {
	Topic      *Topic `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	UnixTimeNs int64  `protobuf:"varint,2,opt,name=unix_time_ns,json=unixTimeNs,proto3" json:"unix_time_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*ClosePublishersRequest) Descriptor deprecated 

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

Deprecated: Use ClosePublishersRequest.ProtoReflect.Descriptor instead.

func (*ClosePublishersRequest) GetTopic 

func (x *ClosePublishersRequest) GetTopic() *Topic

func (*ClosePublishersRequest) GetUnixTimeNs 

func (x *ClosePublishersRequest) GetUnixTimeNs() int64

func (*ClosePublishersRequest) ProtoMessage 

func (*ClosePublishersRequest) ProtoMessage()

func (*ClosePublishersRequest) ProtoReflect 

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

func (*ClosePublishersRequest) Reset 

func (x *ClosePublishersRequest) Reset()

func (*ClosePublishersRequest) String 

func (x *ClosePublishersRequest) String() string

type ClosePublishersResponse 

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

func (*ClosePublishersResponse) Descriptor deprecated 

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

Deprecated: Use ClosePublishersResponse.ProtoReflect.Descriptor instead.

func (*ClosePublishersResponse) ProtoMessage 

func (*ClosePublishersResponse) ProtoMessage()

func (*ClosePublishersResponse) ProtoReflect 

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

func (*ClosePublishersResponse) Reset 

func (x *ClosePublishersResponse) Reset()

func (*ClosePublishersResponse) String 

func (x *ClosePublishersResponse) String() string

type CloseSubscribersRequest 

type CloseSubscribersRequest struct {
	Topic      *Topic `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	UnixTimeNs int64  `protobuf:"varint,2,opt,name=unix_time_ns,json=unixTimeNs,proto3" json:"unix_time_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseSubscribersRequest) Descriptor deprecated 

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

Deprecated: Use CloseSubscribersRequest.ProtoReflect.Descriptor instead.

func (*CloseSubscribersRequest) GetTopic 

func (x *CloseSubscribersRequest) GetTopic() *Topic

func (*CloseSubscribersRequest) GetUnixTimeNs 

func (x *CloseSubscribersRequest) GetUnixTimeNs() int64

func (*CloseSubscribersRequest) ProtoMessage 

func (*CloseSubscribersRequest) ProtoMessage()

func (*CloseSubscribersRequest) ProtoReflect 

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

func (*CloseSubscribersRequest) Reset 

func (x *CloseSubscribersRequest) Reset()

func (*CloseSubscribersRequest) String 

func (x *CloseSubscribersRequest) String() string

type CloseSubscribersResponse 

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

func (*CloseSubscribersResponse) Descriptor deprecated 

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

Deprecated: Use CloseSubscribersResponse.ProtoReflect.Descriptor instead.

func (*CloseSubscribersResponse) ProtoMessage 

func (*CloseSubscribersResponse) ProtoMessage()

func (*CloseSubscribersResponse) ProtoReflect 

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

func (*CloseSubscribersResponse) Reset 

func (x *CloseSubscribersResponse) Reset()

func (*CloseSubscribersResponse) String 

func (x *CloseSubscribersResponse) String() string

type ConfigureTopicRequest 

type ConfigureTopicRequest struct {
	Topic          *Topic                `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	PartitionCount int32                 `protobuf:"varint,2,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"`
	RecordType     *schema_pb.RecordType `protobuf:"bytes,3,opt,name=record_type,json=recordType,proto3" json:"record_type,omitempty"`
	// contains filtered or unexported fields
}

////////////////////////////////////////////////

func (*ConfigureTopicRequest) Descriptor deprecated 

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

Deprecated: Use ConfigureTopicRequest.ProtoReflect.Descriptor instead.

func (*ConfigureTopicRequest) GetPartitionCount 

func (x *ConfigureTopicRequest) GetPartitionCount() int32

func (*ConfigureTopicRequest) GetRecordType 

func (x *ConfigureTopicRequest) GetRecordType() *schema_pb.RecordType

func (*ConfigureTopicRequest) GetTopic 

func (x *ConfigureTopicRequest) GetTopic() *Topic

func (*ConfigureTopicRequest) ProtoMessage 

func (*ConfigureTopicRequest) ProtoMessage()

func (*ConfigureTopicRequest) ProtoReflect 

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

func (*ConfigureTopicRequest) Reset 

func (x *ConfigureTopicRequest) Reset()

func (*ConfigureTopicRequest) String 

func (x *ConfigureTopicRequest) String() string

type ConfigureTopicResponse 

type ConfigureTopicResponse struct {
	BrokerPartitionAssignments []*BrokerPartitionAssignment `` /* 141-byte string literal not displayed */
	RecordType                 *schema_pb.RecordType        `protobuf:"bytes,3,opt,name=record_type,json=recordType,proto3" json:"record_type,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigureTopicResponse) Descriptor deprecated 

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

Deprecated: Use ConfigureTopicResponse.ProtoReflect.Descriptor instead.

func (*ConfigureTopicResponse) GetBrokerPartitionAssignments 

func (x *ConfigureTopicResponse) GetBrokerPartitionAssignments() []*BrokerPartitionAssignment

func (*ConfigureTopicResponse) GetRecordType 

func (x *ConfigureTopicResponse) GetRecordType() *schema_pb.RecordType

func (*ConfigureTopicResponse) ProtoMessage 

func (*ConfigureTopicResponse) ProtoMessage()

func (*ConfigureTopicResponse) ProtoReflect 

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

func (*ConfigureTopicResponse) Reset 

func (x *ConfigureTopicResponse) Reset()

func (*ConfigureTopicResponse) String 

func (x *ConfigureTopicResponse) String() string

type ControlMessage 

type ControlMessage struct {
	IsClose bool `protobuf:"varint,1,opt,name=is_close,json=isClose,proto3" json:"is_close,omitempty"`
	// contains filtered or unexported fields
}

////////////////////////////////////////////////

func (*ControlMessage) Descriptor deprecated 

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

Deprecated: Use ControlMessage.ProtoReflect.Descriptor instead.

func (*ControlMessage) GetIsClose 

func (x *ControlMessage) GetIsClose() bool

func (*ControlMessage) ProtoMessage 

func (*ControlMessage) ProtoMessage()

func (*ControlMessage) ProtoReflect 

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

func (*ControlMessage) Reset 

func (x *ControlMessage) Reset()

func (*ControlMessage) String 

func (x *ControlMessage) String() string

type DataMessage 

type DataMessage struct {
	Key   []byte          `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte          `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	TsNs  int64           `protobuf:"varint,3,opt,name=ts_ns,json=tsNs,proto3" json:"ts_ns,omitempty"`
	Ctrl  *ControlMessage `protobuf:"bytes,4,opt,name=ctrl,proto3" json:"ctrl,omitempty"`
	// contains filtered or unexported fields
}

func (*DataMessage) Descriptor deprecated 

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

Deprecated: Use DataMessage.ProtoReflect.Descriptor instead.

func (*DataMessage) GetCtrl 

func (x *DataMessage) GetCtrl() *ControlMessage

func (*DataMessage) GetKey 

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

func (*DataMessage) GetTsNs 

func (x *DataMessage) GetTsNs() int64

func (*DataMessage) GetValue 

func (x *DataMessage) GetValue() []byte

func (*DataMessage) ProtoMessage 

func (*DataMessage) ProtoMessage()

func (*DataMessage) ProtoReflect 

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

func (*DataMessage) Reset 

func (x *DataMessage) Reset()

func (*DataMessage) String 

func (x *DataMessage) String() string

type FindBrokerLeaderRequest 

type FindBrokerLeaderRequest struct {
	FilerGroup string `protobuf:"bytes,1,opt,name=filer_group,json=filerGroup,proto3" json:"filer_group,omitempty"`
	// contains filtered or unexported fields
}

func (*FindBrokerLeaderRequest) Descriptor deprecated 

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

Deprecated: Use FindBrokerLeaderRequest.ProtoReflect.Descriptor instead.

func (*FindBrokerLeaderRequest) GetFilerGroup 

func (x *FindBrokerLeaderRequest) GetFilerGroup() string

func (*FindBrokerLeaderRequest) ProtoMessage 

func (*FindBrokerLeaderRequest) ProtoMessage()

func (*FindBrokerLeaderRequest) ProtoReflect 

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

func (*FindBrokerLeaderRequest) Reset 

func (x *FindBrokerLeaderRequest) Reset()

func (*FindBrokerLeaderRequest) String 

func (x *FindBrokerLeaderRequest) String() string

type FindBrokerLeaderResponse 

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

func (*FindBrokerLeaderResponse) Descriptor deprecated 

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

Deprecated: Use FindBrokerLeaderResponse.ProtoReflect.Descriptor instead.

func (*FindBrokerLeaderResponse) GetBroker 

func (x *FindBrokerLeaderResponse) GetBroker() string

func (*FindBrokerLeaderResponse) ProtoMessage 

func (*FindBrokerLeaderResponse) ProtoMessage()

func (*FindBrokerLeaderResponse) ProtoReflect 

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

func (*FindBrokerLeaderResponse) Reset 

func (x *FindBrokerLeaderResponse) Reset()

func (*FindBrokerLeaderResponse) String 

func (x *FindBrokerLeaderResponse) String() string

type ListTopicsRequest 

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

func (*ListTopicsRequest) Descriptor deprecated 

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

Deprecated: Use ListTopicsRequest.ProtoReflect.Descriptor instead.

func (*ListTopicsRequest) ProtoMessage 

func (*ListTopicsRequest) ProtoMessage()

func (*ListTopicsRequest) ProtoReflect 

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

func (*ListTopicsRequest) Reset 

func (x *ListTopicsRequest) Reset()

func (*ListTopicsRequest) String 

func (x *ListTopicsRequest) String() string

type ListTopicsResponse 

type ListTopicsResponse struct {
	Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTopicsResponse) Descriptor deprecated 

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

Deprecated: Use ListTopicsResponse.ProtoReflect.Descriptor instead.

func (*ListTopicsResponse) GetTopics 

func (x *ListTopicsResponse) GetTopics() []*Topic

func (*ListTopicsResponse) ProtoMessage 

func (*ListTopicsResponse) ProtoMessage()

func (*ListTopicsResponse) ProtoReflect 

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

func (*ListTopicsResponse) Reset 

func (x *ListTopicsResponse) Reset()

func (*ListTopicsResponse) String 

func (x *ListTopicsResponse) String() string

type LookupTopicBrokersRequest 

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

func (*LookupTopicBrokersRequest) Descriptor deprecated 

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

Deprecated: Use LookupTopicBrokersRequest.ProtoReflect.Descriptor instead.

func (*LookupTopicBrokersRequest) GetTopic 

func (x *LookupTopicBrokersRequest) GetTopic() *Topic

func (*LookupTopicBrokersRequest) ProtoMessage 

func (*LookupTopicBrokersRequest) ProtoMessage()

func (*LookupTopicBrokersRequest) ProtoReflect 

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

func (*LookupTopicBrokersRequest) Reset 

func (x *LookupTopicBrokersRequest) Reset()

func (*LookupTopicBrokersRequest) String 

func (x *LookupTopicBrokersRequest) String() string

type LookupTopicBrokersResponse 

type LookupTopicBrokersResponse struct {
	Topic                      *Topic                       `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	BrokerPartitionAssignments []*BrokerPartitionAssignment `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LookupTopicBrokersResponse) Descriptor deprecated 

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

Deprecated: Use LookupTopicBrokersResponse.ProtoReflect.Descriptor instead.

func (*LookupTopicBrokersResponse) GetBrokerPartitionAssignments 

func (x *LookupTopicBrokersResponse) GetBrokerPartitionAssignments() []*BrokerPartitionAssignment

func (*LookupTopicBrokersResponse) GetTopic 

func (x *LookupTopicBrokersResponse) GetTopic() *Topic

func (*LookupTopicBrokersResponse) ProtoMessage 

func (*LookupTopicBrokersResponse) ProtoMessage()

func (*LookupTopicBrokersResponse) ProtoReflect 

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

func (*LookupTopicBrokersResponse) Reset 

func (x *LookupTopicBrokersResponse) Reset()

func (*LookupTopicBrokersResponse) String 

func (x *LookupTopicBrokersResponse) String() string

type Offset 

type Offset struct {
	Topic            *Topic             `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	PartitionOffsets []*PartitionOffset `protobuf:"bytes,2,rep,name=partition_offsets,json=partitionOffsets,proto3" json:"partition_offsets,omitempty"`
	// contains filtered or unexported fields
}

func (*Offset) Descriptor deprecated 

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

Deprecated: Use Offset.ProtoReflect.Descriptor instead.

func (*Offset) GetPartitionOffsets 

func (x *Offset) GetPartitionOffsets() []*PartitionOffset

func (*Offset) GetTopic 

func (x *Offset) GetTopic() *Topic

func (*Offset) ProtoMessage 

func (*Offset) ProtoMessage()

func (*Offset) ProtoReflect 

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

func (*Offset) Reset 

func (x *Offset) Reset()

func (*Offset) String 

func (x *Offset) String() string

type Partition 

type Partition struct {
	RingSize   int32 `protobuf:"varint,1,opt,name=ring_size,json=ringSize,proto3" json:"ring_size,omitempty"`
	RangeStart int32 `protobuf:"varint,2,opt,name=range_start,json=rangeStart,proto3" json:"range_start,omitempty"`
	RangeStop  int32 `protobuf:"varint,3,opt,name=range_stop,json=rangeStop,proto3" json:"range_stop,omitempty"`
	UnixTimeNs int64 `protobuf:"varint,4,opt,name=unix_time_ns,json=unixTimeNs,proto3" json:"unix_time_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*Partition) Descriptor deprecated 

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

Deprecated: Use Partition.ProtoReflect.Descriptor instead.

func (*Partition) GetRangeStart 

func (x *Partition) GetRangeStart() int32

func (*Partition) GetRangeStop 

func (x *Partition) GetRangeStop() int32

func (*Partition) GetRingSize 

func (x *Partition) GetRingSize() int32

func (*Partition) GetUnixTimeNs 

func (x *Partition) GetUnixTimeNs() int64

func (*Partition) ProtoMessage 

func (*Partition) ProtoMessage()

func (*Partition) ProtoReflect 

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

func (*Partition) Reset 

func (x *Partition) Reset()

func (*Partition) String 

func (x *Partition) String() string

type PartitionOffset 

type PartitionOffset struct {
	Partition *Partition               `protobuf:"bytes,1,opt,name=partition,proto3" json:"partition,omitempty"`
	StartTsNs int64                    `protobuf:"varint,2,opt,name=start_ts_ns,json=startTsNs,proto3" json:"start_ts_ns,omitempty"`
	StopTsNs  int64                    `protobuf:"varint,3,opt,name=stop_ts_ns,json=stopTsNs,proto3" json:"stop_ts_ns,omitempty"`
	StartType PartitionOffsetStartType `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PartitionOffset) Descriptor deprecated 

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

Deprecated: Use PartitionOffset.ProtoReflect.Descriptor instead.

func (*PartitionOffset) GetPartition 

func (x *PartitionOffset) GetPartition() *Partition

func (*PartitionOffset) GetStartTsNs 

func (x *PartitionOffset) GetStartTsNs() int64

func (*PartitionOffset) GetStartType 

func (x *PartitionOffset) GetStartType() PartitionOffsetStartType

func (*PartitionOffset) GetStopTsNs 

func (x *PartitionOffset) GetStopTsNs() int64

func (*PartitionOffset) ProtoMessage 

func (*PartitionOffset) ProtoMessage()

func (*PartitionOffset) ProtoReflect 

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

func (*PartitionOffset) Reset 

func (x *PartitionOffset) Reset()

func (*PartitionOffset) String 

func (x *PartitionOffset) String() string

type PartitionOffsetStartType 

type PartitionOffsetStartType int32
const (
	PartitionOffsetStartType_EARLIEST           PartitionOffsetStartType = 0
	PartitionOffsetStartType_EARLIEST_IN_MEMORY PartitionOffsetStartType = 1
	PartitionOffsetStartType_LATEST             PartitionOffsetStartType = 2
)

func (PartitionOffsetStartType) Descriptor 

func (PartitionOffsetStartType) Descriptor() protoreflect.EnumDescriptor

func (PartitionOffsetStartType) Enum 

func (x PartitionOffsetStartType) Enum() *PartitionOffsetStartType

func (PartitionOffsetStartType) EnumDescriptor deprecated 

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

Deprecated: Use PartitionOffsetStartType.Descriptor instead.

func (PartitionOffsetStartType) Number 

func (x PartitionOffsetStartType) Number() protoreflect.EnumNumber

func (PartitionOffsetStartType) String 

func (x PartitionOffsetStartType) String() string

func (PartitionOffsetStartType) Type 

func (PartitionOffsetStartType) Type() protoreflect.EnumType

type PublishFollowMeRequest 

type PublishFollowMeRequest struct {

	// Types that are assignable to Message:
	//
	//	*PublishFollowMeRequest_Init
	//	*PublishFollowMeRequest_Data
	//	*PublishFollowMeRequest_Flush
	//	*PublishFollowMeRequest_Close
	Message isPublishFollowMeRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*PublishFollowMeRequest) Descriptor deprecated 

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

Deprecated: Use PublishFollowMeRequest.ProtoReflect.Descriptor instead.

func (*PublishFollowMeRequest) GetClose 

func (x *PublishFollowMeRequest) GetClose() *PublishFollowMeRequest_CloseMessage

func (*PublishFollowMeRequest) GetData 

func (x *PublishFollowMeRequest) GetData() *DataMessage

func (*PublishFollowMeRequest) GetFlush 

func (x *PublishFollowMeRequest) GetFlush() *PublishFollowMeRequest_FlushMessage

func (*PublishFollowMeRequest) GetInit 

func (x *PublishFollowMeRequest) GetInit() *PublishFollowMeRequest_InitMessage

func (*PublishFollowMeRequest) GetMessage 

func (m *PublishFollowMeRequest) GetMessage() isPublishFollowMeRequest_Message

func (*PublishFollowMeRequest) ProtoMessage 

func (*PublishFollowMeRequest) ProtoMessage()

func (*PublishFollowMeRequest) ProtoReflect 

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

func (*PublishFollowMeRequest) Reset 

func (x *PublishFollowMeRequest) Reset()

func (*PublishFollowMeRequest) String 

func (x *PublishFollowMeRequest) String() string

type PublishFollowMeRequest_Close 

type PublishFollowMeRequest_Close struct {
	Close *PublishFollowMeRequest_CloseMessage `protobuf:"bytes,4,opt,name=close,proto3,oneof"`
}

type PublishFollowMeRequest_CloseMessage 

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

func (*PublishFollowMeRequest_CloseMessage) Descriptor deprecated 

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

Deprecated: Use PublishFollowMeRequest_CloseMessage.ProtoReflect.Descriptor instead.

func (*PublishFollowMeRequest_CloseMessage) ProtoMessage 

func (*PublishFollowMeRequest_CloseMessage) ProtoMessage()

func (*PublishFollowMeRequest_CloseMessage) ProtoReflect 

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

func (*PublishFollowMeRequest_CloseMessage) Reset 

func (x *PublishFollowMeRequest_CloseMessage) Reset()

func (*PublishFollowMeRequest_CloseMessage) String 

func (x *PublishFollowMeRequest_CloseMessage) String() string

type PublishFollowMeRequest_Data 

type PublishFollowMeRequest_Data struct {
	Data *DataMessage `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type PublishFollowMeRequest_Flush 

type PublishFollowMeRequest_Flush struct {
	Flush *PublishFollowMeRequest_FlushMessage `protobuf:"bytes,3,opt,name=flush,proto3,oneof"`
}

type PublishFollowMeRequest_FlushMessage 

type PublishFollowMeRequest_FlushMessage struct {
	TsNs int64 `protobuf:"varint,1,opt,name=ts_ns,json=tsNs,proto3" json:"ts_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishFollowMeRequest_FlushMessage) Descriptor deprecated 

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

Deprecated: Use PublishFollowMeRequest_FlushMessage.ProtoReflect.Descriptor instead.

func (*PublishFollowMeRequest_FlushMessage) GetTsNs 

func (x *PublishFollowMeRequest_FlushMessage) GetTsNs() int64

func (*PublishFollowMeRequest_FlushMessage) ProtoMessage 

func (*PublishFollowMeRequest_FlushMessage) ProtoMessage()

func (*PublishFollowMeRequest_FlushMessage) ProtoReflect 

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

func (*PublishFollowMeRequest_FlushMessage) Reset 

func (x *PublishFollowMeRequest_FlushMessage) Reset()

func (*PublishFollowMeRequest_FlushMessage) String 

func (x *PublishFollowMeRequest_FlushMessage) String() string

type PublishFollowMeRequest_Init 

type PublishFollowMeRequest_Init struct {
	Init *PublishFollowMeRequest_InitMessage `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type PublishFollowMeRequest_InitMessage 

type PublishFollowMeRequest_InitMessage struct {
	Topic     *Topic     `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition *Partition `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishFollowMeRequest_InitMessage) Descriptor deprecated 

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

Deprecated: Use PublishFollowMeRequest_InitMessage.ProtoReflect.Descriptor instead.

func (*PublishFollowMeRequest_InitMessage) GetPartition 

func (x *PublishFollowMeRequest_InitMessage) GetPartition() *Partition

func (*PublishFollowMeRequest_InitMessage) GetTopic 

func (x *PublishFollowMeRequest_InitMessage) GetTopic() *Topic

func (*PublishFollowMeRequest_InitMessage) ProtoMessage 

func (*PublishFollowMeRequest_InitMessage) ProtoMessage()

func (*PublishFollowMeRequest_InitMessage) ProtoReflect 

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

func (*PublishFollowMeRequest_InitMessage) Reset 

func (x *PublishFollowMeRequest_InitMessage) Reset()

func (*PublishFollowMeRequest_InitMessage) String 

func (x *PublishFollowMeRequest_InitMessage) String() string

type PublishFollowMeResponse 

type PublishFollowMeResponse struct {
	AckTsNs int64 `protobuf:"varint,1,opt,name=ack_ts_ns,json=ackTsNs,proto3" json:"ack_ts_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishFollowMeResponse) Descriptor deprecated 

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

Deprecated: Use PublishFollowMeResponse.ProtoReflect.Descriptor instead.

func (*PublishFollowMeResponse) GetAckTsNs 

func (x *PublishFollowMeResponse) GetAckTsNs() int64

func (*PublishFollowMeResponse) ProtoMessage 

func (*PublishFollowMeResponse) ProtoMessage()

func (*PublishFollowMeResponse) ProtoReflect 

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

func (*PublishFollowMeResponse) Reset 

func (x *PublishFollowMeResponse) Reset()

func (*PublishFollowMeResponse) String 

func (x *PublishFollowMeResponse) String() string

type PublishMessageRequest 

type PublishMessageRequest struct {

	// Types that are assignable to Message:
	//
	//	*PublishMessageRequest_Init
	//	*PublishMessageRequest_Data
	Message  isPublishMessageRequest_Message `protobuf_oneof:"message"`
	Sequence int64                           `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishMessageRequest) Descriptor deprecated 

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

Deprecated: Use PublishMessageRequest.ProtoReflect.Descriptor instead.

func (*PublishMessageRequest) GetData 

func (x *PublishMessageRequest) GetData() *DataMessage

func (*PublishMessageRequest) GetInit 

func (x *PublishMessageRequest) GetInit() *PublishMessageRequest_InitMessage

func (*PublishMessageRequest) GetMessage 

func (m *PublishMessageRequest) GetMessage() isPublishMessageRequest_Message

func (*PublishMessageRequest) GetSequence 

func (x *PublishMessageRequest) GetSequence() int64

func (*PublishMessageRequest) ProtoMessage 

func (*PublishMessageRequest) ProtoMessage()

func (*PublishMessageRequest) ProtoReflect 

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

func (*PublishMessageRequest) Reset 

func (x *PublishMessageRequest) Reset()

func (*PublishMessageRequest) String 

func (x *PublishMessageRequest) String() string

type PublishMessageRequest_Data 

type PublishMessageRequest_Data struct {
	Data *DataMessage `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type PublishMessageRequest_Init 

type PublishMessageRequest_Init struct {
	Init *PublishMessageRequest_InitMessage `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type PublishMessageRequest_InitMessage 

type PublishMessageRequest_InitMessage struct {
	Topic           *Topic     `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition       *Partition `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	AckInterval     int32      `protobuf:"varint,3,opt,name=ack_interval,json=ackInterval,proto3" json:"ack_interval,omitempty"`
	FollowerBrokers []string   `protobuf:"bytes,4,rep,name=follower_brokers,json=followerBrokers,proto3" json:"follower_brokers,omitempty"`
	PublisherName   string     `protobuf:"bytes,5,opt,name=publisher_name,json=publisherName,proto3" json:"publisher_name,omitempty"` // for debugging
	// contains filtered or unexported fields
}

func (*PublishMessageRequest_InitMessage) Descriptor deprecated 

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

Deprecated: Use PublishMessageRequest_InitMessage.ProtoReflect.Descriptor instead.

func (*PublishMessageRequest_InitMessage) GetAckInterval 

func (x *PublishMessageRequest_InitMessage) GetAckInterval() int32

func (*PublishMessageRequest_InitMessage) GetFollowerBrokers 

func (x *PublishMessageRequest_InitMessage) GetFollowerBrokers() []string

func (*PublishMessageRequest_InitMessage) GetPartition 

func (x *PublishMessageRequest_InitMessage) GetPartition() *Partition

func (*PublishMessageRequest_InitMessage) GetPublisherName 

func (x *PublishMessageRequest_InitMessage) GetPublisherName() string

func (*PublishMessageRequest_InitMessage) GetTopic 

func (x *PublishMessageRequest_InitMessage) GetTopic() *Topic

func (*PublishMessageRequest_InitMessage) ProtoMessage 

func (*PublishMessageRequest_InitMessage) ProtoMessage()

func (*PublishMessageRequest_InitMessage) ProtoReflect 

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

func (*PublishMessageRequest_InitMessage) Reset 

func (x *PublishMessageRequest_InitMessage) Reset()

func (*PublishMessageRequest_InitMessage) String 

func (x *PublishMessageRequest_InitMessage) String() string

type PublishMessageResponse 

type PublishMessageResponse struct {
	AckSequence int64  `protobuf:"varint,1,opt,name=ack_sequence,json=ackSequence,proto3" json:"ack_sequence,omitempty"`
	Error       string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	ShouldClose bool   `protobuf:"varint,3,opt,name=should_close,json=shouldClose,proto3" json:"should_close,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishMessageResponse) Descriptor deprecated 

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

Deprecated: Use PublishMessageResponse.ProtoReflect.Descriptor instead.

func (*PublishMessageResponse) GetAckSequence 

func (x *PublishMessageResponse) GetAckSequence() int64

func (*PublishMessageResponse) GetError 

func (x *PublishMessageResponse) GetError() string

func (*PublishMessageResponse) GetShouldClose 

func (x *PublishMessageResponse) GetShouldClose() bool

func (*PublishMessageResponse) ProtoMessage 

func (*PublishMessageResponse) ProtoMessage()

func (*PublishMessageResponse) ProtoReflect 

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

func (*PublishMessageResponse) Reset 

func (x *PublishMessageResponse) Reset()

func (*PublishMessageResponse) String 

func (x *PublishMessageResponse) String() string

type PublisherToPubBalancerRequest 

type PublisherToPubBalancerRequest struct {

	// Types that are assignable to Message:
	//
	//	*PublisherToPubBalancerRequest_Init
	//	*PublisherToPubBalancerRequest_Stats
	Message isPublisherToPubBalancerRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*PublisherToPubBalancerRequest) Descriptor deprecated 

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

Deprecated: Use PublisherToPubBalancerRequest.ProtoReflect.Descriptor instead.

func (*PublisherToPubBalancerRequest) GetInit 

func (x *PublisherToPubBalancerRequest) GetInit() *PublisherToPubBalancerRequest_InitMessage

func (*PublisherToPubBalancerRequest) GetMessage 

func (m *PublisherToPubBalancerRequest) GetMessage() isPublisherToPubBalancerRequest_Message

func (*PublisherToPubBalancerRequest) GetStats 

func (x *PublisherToPubBalancerRequest) GetStats() *BrokerStats

func (*PublisherToPubBalancerRequest) ProtoMessage 

func (*PublisherToPubBalancerRequest) ProtoMessage()

func (*PublisherToPubBalancerRequest) ProtoReflect 

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

func (*PublisherToPubBalancerRequest) Reset 

func (x *PublisherToPubBalancerRequest) Reset()

func (*PublisherToPubBalancerRequest) String 

func (x *PublisherToPubBalancerRequest) String() string

type PublisherToPubBalancerRequest_Init 

type PublisherToPubBalancerRequest_Init struct {
	Init *PublisherToPubBalancerRequest_InitMessage `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type PublisherToPubBalancerRequest_InitMessage 

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

func (*PublisherToPubBalancerRequest_InitMessage) Descriptor deprecated 

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

Deprecated: Use PublisherToPubBalancerRequest_InitMessage.ProtoReflect.Descriptor instead.

func (*PublisherToPubBalancerRequest_InitMessage) GetBroker 

func (x *PublisherToPubBalancerRequest_InitMessage) GetBroker() string

func (*PublisherToPubBalancerRequest_InitMessage) ProtoMessage 

func (*PublisherToPubBalancerRequest_InitMessage) ProtoMessage()

func (*PublisherToPubBalancerRequest_InitMessage) ProtoReflect 

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

func (*PublisherToPubBalancerRequest_InitMessage) Reset 

func (x *PublisherToPubBalancerRequest_InitMessage) Reset()

func (*PublisherToPubBalancerRequest_InitMessage) String 

func (x *PublisherToPubBalancerRequest_InitMessage) String() string

type PublisherToPubBalancerRequest_Stats 

type PublisherToPubBalancerRequest_Stats struct {
	Stats *BrokerStats `protobuf:"bytes,2,opt,name=stats,proto3,oneof"`
}

type PublisherToPubBalancerResponse 

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

func (*PublisherToPubBalancerResponse) Descriptor deprecated 

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

Deprecated: Use PublisherToPubBalancerResponse.ProtoReflect.Descriptor instead.

func (*PublisherToPubBalancerResponse) ProtoMessage 

func (*PublisherToPubBalancerResponse) ProtoMessage()

func (*PublisherToPubBalancerResponse) ProtoReflect 

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

func (*PublisherToPubBalancerResponse) Reset 

func (x *PublisherToPubBalancerResponse) Reset()

func (*PublisherToPubBalancerResponse) String 

func (x *PublisherToPubBalancerResponse) String() string

type SeaweedMessagingClient 

type SeaweedMessagingClient interface {
	// control plane
	FindBrokerLeader(ctx context.Context, in *FindBrokerLeaderRequest, opts ...grpc.CallOption) (*FindBrokerLeaderResponse, error)
	// control plane for balancer
	PublisherToPubBalancer(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_PublisherToPubBalancerClient, error)
	BalanceTopics(ctx context.Context, in *BalanceTopicsRequest, opts ...grpc.CallOption) (*BalanceTopicsResponse, error)
	// control plane for topic partitions
	ListTopics(ctx context.Context, in *ListTopicsRequest, opts ...grpc.CallOption) (*ListTopicsResponse, error)
	ConfigureTopic(ctx context.Context, in *ConfigureTopicRequest, opts ...grpc.CallOption) (*ConfigureTopicResponse, error)
	LookupTopicBrokers(ctx context.Context, in *LookupTopicBrokersRequest, opts ...grpc.CallOption) (*LookupTopicBrokersResponse, error)
	// invoked by the balancer, running on each broker
	AssignTopicPartitions(ctx context.Context, in *AssignTopicPartitionsRequest, opts ...grpc.CallOption) (*AssignTopicPartitionsResponse, error)
	ClosePublishers(ctx context.Context, in *ClosePublishersRequest, opts ...grpc.CallOption) (*ClosePublishersResponse, error)
	CloseSubscribers(ctx context.Context, in *CloseSubscribersRequest, opts ...grpc.CallOption) (*CloseSubscribersResponse, error)
	// subscriber connects to broker balancer, which coordinates with the subscribers
	SubscriberToSubCoordinator(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_SubscriberToSubCoordinatorClient, error)
	// data plane for each topic partition
	PublishMessage(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_PublishMessageClient, error)
	SubscribeMessage(ctx context.Context, in *SubscribeMessageRequest, opts ...grpc.CallOption) (SeaweedMessaging_SubscribeMessageClient, error)
	// The lead broker asks a follower broker to follow itself
	PublishFollowMe(ctx context.Context, opts ...grpc.CallOption) (SeaweedMessaging_PublishFollowMeClient, error)
}

SeaweedMessagingClient is the client API for SeaweedMessaging 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 NewSeaweedMessagingClient 

func NewSeaweedMessagingClient(cc grpc.ClientConnInterface) SeaweedMessagingClient

type SeaweedMessagingServer 

type SeaweedMessagingServer interface {
	// control plane
	FindBrokerLeader(context.Context, *FindBrokerLeaderRequest) (*FindBrokerLeaderResponse, error)
	// control plane for balancer
	PublisherToPubBalancer(SeaweedMessaging_PublisherToPubBalancerServer) error
	BalanceTopics(context.Context, *BalanceTopicsRequest) (*BalanceTopicsResponse, error)
	// control plane for topic partitions
	ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)
	ConfigureTopic(context.Context, *ConfigureTopicRequest) (*ConfigureTopicResponse, error)
	LookupTopicBrokers(context.Context, *LookupTopicBrokersRequest) (*LookupTopicBrokersResponse, error)
	// invoked by the balancer, running on each broker
	AssignTopicPartitions(context.Context, *AssignTopicPartitionsRequest) (*AssignTopicPartitionsResponse, error)
	ClosePublishers(context.Context, *ClosePublishersRequest) (*ClosePublishersResponse, error)
	CloseSubscribers(context.Context, *CloseSubscribersRequest) (*CloseSubscribersResponse, error)
	// subscriber connects to broker balancer, which coordinates with the subscribers
	SubscriberToSubCoordinator(SeaweedMessaging_SubscriberToSubCoordinatorServer) error
	// data plane for each topic partition
	PublishMessage(SeaweedMessaging_PublishMessageServer) error
	SubscribeMessage(*SubscribeMessageRequest, SeaweedMessaging_SubscribeMessageServer) error
	// The lead broker asks a follower broker to follow itself
	PublishFollowMe(SeaweedMessaging_PublishFollowMeServer) error
	// contains filtered or unexported methods
}

SeaweedMessagingServer is the server API for SeaweedMessaging service. All implementations must embed UnimplementedSeaweedMessagingServer for forward compatibility

type SeaweedMessaging_PublishFollowMeClient 

type SeaweedMessaging_PublishFollowMeClient interface {
	Send(*PublishFollowMeRequest) error
	Recv() (*PublishFollowMeResponse, error)
	grpc.ClientStream
}

type SeaweedMessaging_PublishFollowMeServer 

type SeaweedMessaging_PublishFollowMeServer interface {
	Send(*PublishFollowMeResponse) error
	Recv() (*PublishFollowMeRequest, error)
	grpc.ServerStream
}

type SeaweedMessaging_PublishMessageClient 

type SeaweedMessaging_PublishMessageClient interface {
	Send(*PublishMessageRequest) error
	Recv() (*PublishMessageResponse, error)
	grpc.ClientStream
}

type SeaweedMessaging_PublishMessageServer 

type SeaweedMessaging_PublishMessageServer interface {
	Send(*PublishMessageResponse) error
	Recv() (*PublishMessageRequest, error)
	grpc.ServerStream
}

type SeaweedMessaging_PublisherToPubBalancerClient 

type SeaweedMessaging_PublisherToPubBalancerClient interface {
	Send(*PublisherToPubBalancerRequest) error
	Recv() (*PublisherToPubBalancerResponse, error)
	grpc.ClientStream
}

type SeaweedMessaging_PublisherToPubBalancerServer 

type SeaweedMessaging_PublisherToPubBalancerServer interface {
	Send(*PublisherToPubBalancerResponse) error
	Recv() (*PublisherToPubBalancerRequest, error)
	grpc.ServerStream
}

type SeaweedMessaging_SubscribeMessageClient 

type SeaweedMessaging_SubscribeMessageClient interface {
	Recv() (*SubscribeMessageResponse, error)
	grpc.ClientStream
}

type SeaweedMessaging_SubscribeMessageServer 

type SeaweedMessaging_SubscribeMessageServer interface {
	Send(*SubscribeMessageResponse) error
	grpc.ServerStream
}

type SeaweedMessaging_SubscriberToSubCoordinatorClient 

type SeaweedMessaging_SubscriberToSubCoordinatorClient interface {
	Send(*SubscriberToSubCoordinatorRequest) error
	Recv() (*SubscriberToSubCoordinatorResponse, error)
	grpc.ClientStream
}

type SeaweedMessaging_SubscriberToSubCoordinatorServer 

type SeaweedMessaging_SubscriberToSubCoordinatorServer interface {
	Send(*SubscriberToSubCoordinatorResponse) error
	Recv() (*SubscriberToSubCoordinatorRequest, error)
	grpc.ServerStream
}

type SubscribeMessageRequest 

type SubscribeMessageRequest struct {

	// Types that are assignable to Message:
	//
	//	*SubscribeMessageRequest_Init
	//	*SubscribeMessageRequest_Ack
	Message isSubscribeMessageRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*SubscribeMessageRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeMessageRequest.ProtoReflect.Descriptor instead.

func (*SubscribeMessageRequest) GetAck 

func (x *SubscribeMessageRequest) GetAck() *SubscribeMessageRequest_AckMessage

func (*SubscribeMessageRequest) GetInit 

func (x *SubscribeMessageRequest) GetInit() *SubscribeMessageRequest_InitMessage

func (*SubscribeMessageRequest) GetMessage 

func (m *SubscribeMessageRequest) GetMessage() isSubscribeMessageRequest_Message

func (*SubscribeMessageRequest) ProtoMessage 

func (*SubscribeMessageRequest) ProtoMessage()

func (*SubscribeMessageRequest) ProtoReflect 

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

func (*SubscribeMessageRequest) Reset 

func (x *SubscribeMessageRequest) Reset()

func (*SubscribeMessageRequest) String 

func (x *SubscribeMessageRequest) String() string

type SubscribeMessageRequest_Ack 

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

type SubscribeMessageRequest_AckMessage 

type SubscribeMessageRequest_AckMessage struct {
	Sequence int64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeMessageRequest_AckMessage) Descriptor deprecated 

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

Deprecated: Use SubscribeMessageRequest_AckMessage.ProtoReflect.Descriptor instead.

func (*SubscribeMessageRequest_AckMessage) GetSequence 

func (x *SubscribeMessageRequest_AckMessage) GetSequence() int64

func (*SubscribeMessageRequest_AckMessage) ProtoMessage 

func (*SubscribeMessageRequest_AckMessage) ProtoMessage()

func (*SubscribeMessageRequest_AckMessage) ProtoReflect 

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

func (*SubscribeMessageRequest_AckMessage) Reset 

func (x *SubscribeMessageRequest_AckMessage) Reset()

func (*SubscribeMessageRequest_AckMessage) String 

func (x *SubscribeMessageRequest_AckMessage) String() string

type SubscribeMessageRequest_Init 

type SubscribeMessageRequest_Init struct {
	Init *SubscribeMessageRequest_InitMessage `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type SubscribeMessageRequest_InitMessage 

type SubscribeMessageRequest_InitMessage struct {
	ConsumerGroup   string           `protobuf:"bytes,1,opt,name=consumer_group,json=consumerGroup,proto3" json:"consumer_group,omitempty"`
	ConsumerId      string           `protobuf:"bytes,2,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"`
	ClientId        string           `protobuf:"bytes,3,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Topic           *Topic           `protobuf:"bytes,4,opt,name=topic,proto3" json:"topic,omitempty"`
	PartitionOffset *PartitionOffset `protobuf:"bytes,5,opt,name=partition_offset,json=partitionOffset,proto3" json:"partition_offset,omitempty"`
	Filter          string           `protobuf:"bytes,6,opt,name=filter,proto3" json:"filter,omitempty"`
	FollowerBrokers []string         `protobuf:"bytes,7,rep,name=follower_brokers,json=followerBrokers,proto3" json:"follower_brokers,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeMessageRequest_InitMessage) Descriptor deprecated 

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

Deprecated: Use SubscribeMessageRequest_InitMessage.ProtoReflect.Descriptor instead.

func (*SubscribeMessageRequest_InitMessage) GetClientId 

func (x *SubscribeMessageRequest_InitMessage) GetClientId() string

func (*SubscribeMessageRequest_InitMessage) GetConsumerGroup 

func (x *SubscribeMessageRequest_InitMessage) GetConsumerGroup() string

func (*SubscribeMessageRequest_InitMessage) GetConsumerId 

func (x *SubscribeMessageRequest_InitMessage) GetConsumerId() string

func (*SubscribeMessageRequest_InitMessage) GetFilter 

func (x *SubscribeMessageRequest_InitMessage) GetFilter() string

func (*SubscribeMessageRequest_InitMessage) GetFollowerBrokers 

func (x *SubscribeMessageRequest_InitMessage) GetFollowerBrokers() []string

func (*SubscribeMessageRequest_InitMessage) GetPartitionOffset 

func (x *SubscribeMessageRequest_InitMessage) GetPartitionOffset() *PartitionOffset

func (*SubscribeMessageRequest_InitMessage) GetTopic 

func (x *SubscribeMessageRequest_InitMessage) GetTopic() *Topic

func (*SubscribeMessageRequest_InitMessage) ProtoMessage 

func (*SubscribeMessageRequest_InitMessage) ProtoMessage()

func (*SubscribeMessageRequest_InitMessage) ProtoReflect 

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

func (*SubscribeMessageRequest_InitMessage) Reset 

func (x *SubscribeMessageRequest_InitMessage) Reset()

func (*SubscribeMessageRequest_InitMessage) String 

func (x *SubscribeMessageRequest_InitMessage) String() string

type SubscribeMessageResponse 

type SubscribeMessageResponse struct {

	// Types that are assignable to Message:
	//
	//	*SubscribeMessageResponse_Ctrl
	//	*SubscribeMessageResponse_Data
	Message isSubscribeMessageResponse_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*SubscribeMessageResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeMessageResponse.ProtoReflect.Descriptor instead.

func (*SubscribeMessageResponse) GetCtrl 

func (x *SubscribeMessageResponse) GetCtrl() *SubscribeMessageResponse_SubscribeCtrlMessage

func (*SubscribeMessageResponse) GetData 

func (x *SubscribeMessageResponse) GetData() *DataMessage

func (*SubscribeMessageResponse) GetMessage 

func (m *SubscribeMessageResponse) GetMessage() isSubscribeMessageResponse_Message

func (*SubscribeMessageResponse) ProtoMessage 

func (*SubscribeMessageResponse) ProtoMessage()

func (*SubscribeMessageResponse) ProtoReflect 

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

func (*SubscribeMessageResponse) Reset 

func (x *SubscribeMessageResponse) Reset()

func (*SubscribeMessageResponse) String 

func (x *SubscribeMessageResponse) String() string

type SubscribeMessageResponse_Ctrl 

type SubscribeMessageResponse_Ctrl struct {
	Ctrl *SubscribeMessageResponse_SubscribeCtrlMessage `protobuf:"bytes,1,opt,name=ctrl,proto3,oneof"`
}

type SubscribeMessageResponse_Data 

type SubscribeMessageResponse_Data struct {
	Data *DataMessage `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type SubscribeMessageResponse_SubscribeCtrlMessage 

type SubscribeMessageResponse_SubscribeCtrlMessage struct {
	Error         string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	IsEndOfStream bool   `protobuf:"varint,2,opt,name=is_end_of_stream,json=isEndOfStream,proto3" json:"is_end_of_stream,omitempty"`
	IsEndOfTopic  bool   `protobuf:"varint,3,opt,name=is_end_of_topic,json=isEndOfTopic,proto3" json:"is_end_of_topic,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeMessageResponse_SubscribeCtrlMessage) Descriptor deprecated 

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

Deprecated: Use SubscribeMessageResponse_SubscribeCtrlMessage.ProtoReflect.Descriptor instead.

func (*SubscribeMessageResponse_SubscribeCtrlMessage) GetError 

func (x *SubscribeMessageResponse_SubscribeCtrlMessage) GetError() string

func (*SubscribeMessageResponse_SubscribeCtrlMessage) GetIsEndOfStream 

func (x *SubscribeMessageResponse_SubscribeCtrlMessage) GetIsEndOfStream() bool

func (*SubscribeMessageResponse_SubscribeCtrlMessage) GetIsEndOfTopic 

func (x *SubscribeMessageResponse_SubscribeCtrlMessage) GetIsEndOfTopic() bool

func (*SubscribeMessageResponse_SubscribeCtrlMessage) ProtoMessage 

func (*SubscribeMessageResponse_SubscribeCtrlMessage) ProtoMessage()

func (*SubscribeMessageResponse_SubscribeCtrlMessage) ProtoReflect 

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

func (*SubscribeMessageResponse_SubscribeCtrlMessage) Reset 

func (x *SubscribeMessageResponse_SubscribeCtrlMessage) Reset()

func (*SubscribeMessageResponse_SubscribeCtrlMessage) String 

func (x *SubscribeMessageResponse_SubscribeCtrlMessage) String() string

type SubscriberToSubCoordinatorRequest 

type SubscriberToSubCoordinatorRequest struct {

	// Types that are assignable to Message:
	//
	//	*SubscriberToSubCoordinatorRequest_Init
	//	*SubscriberToSubCoordinatorRequest_Ack
	Message isSubscriberToSubCoordinatorRequest_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*SubscriberToSubCoordinatorRequest) Descriptor deprecated 

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

Deprecated: Use SubscriberToSubCoordinatorRequest.ProtoReflect.Descriptor instead.

func (*SubscriberToSubCoordinatorRequest) GetAck 

func (x *SubscriberToSubCoordinatorRequest) GetAck() *SubscriberToSubCoordinatorRequest_AckMessage

func (*SubscriberToSubCoordinatorRequest) GetInit 

func (x *SubscriberToSubCoordinatorRequest) GetInit() *SubscriberToSubCoordinatorRequest_InitMessage

func (*SubscriberToSubCoordinatorRequest) GetMessage 

func (m *SubscriberToSubCoordinatorRequest) GetMessage() isSubscriberToSubCoordinatorRequest_Message

func (*SubscriberToSubCoordinatorRequest) ProtoMessage 

func (*SubscriberToSubCoordinatorRequest) ProtoMessage()

func (*SubscriberToSubCoordinatorRequest) ProtoReflect 

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

func (*SubscriberToSubCoordinatorRequest) Reset 

func (x *SubscriberToSubCoordinatorRequest) Reset()

func (*SubscriberToSubCoordinatorRequest) String 

func (x *SubscriberToSubCoordinatorRequest) String() string

type SubscriberToSubCoordinatorRequest_Ack 

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

type SubscriberToSubCoordinatorRequest_AckMessage 

type SubscriberToSubCoordinatorRequest_AckMessage struct {
	Partition *Partition `protobuf:"bytes,1,opt,name=partition,proto3" json:"partition,omitempty"`
	TsNs      int64      `protobuf:"varint,2,opt,name=ts_ns,json=tsNs,proto3" json:"ts_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriberToSubCoordinatorRequest_AckMessage) Descriptor deprecated 

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

Deprecated: Use SubscriberToSubCoordinatorRequest_AckMessage.ProtoReflect.Descriptor instead.

func (*SubscriberToSubCoordinatorRequest_AckMessage) GetPartition 

func (x *SubscriberToSubCoordinatorRequest_AckMessage) GetPartition() *Partition

func (*SubscriberToSubCoordinatorRequest_AckMessage) GetTsNs 

func (x *SubscriberToSubCoordinatorRequest_AckMessage) GetTsNs() int64

func (*SubscriberToSubCoordinatorRequest_AckMessage) ProtoMessage 

func (*SubscriberToSubCoordinatorRequest_AckMessage) ProtoMessage()

func (*SubscriberToSubCoordinatorRequest_AckMessage) ProtoReflect 

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

func (*SubscriberToSubCoordinatorRequest_AckMessage) Reset 

func (x *SubscriberToSubCoordinatorRequest_AckMessage) Reset()

func (*SubscriberToSubCoordinatorRequest_AckMessage) String 

func (x *SubscriberToSubCoordinatorRequest_AckMessage) String() string

type SubscriberToSubCoordinatorRequest_Init 

type SubscriberToSubCoordinatorRequest_Init struct {
	Init *SubscriberToSubCoordinatorRequest_InitMessage `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type SubscriberToSubCoordinatorRequest_InitMessage 

type SubscriberToSubCoordinatorRequest_InitMessage struct {
	ConsumerGroup           string `protobuf:"bytes,1,opt,name=consumer_group,json=consumerGroup,proto3" json:"consumer_group,omitempty"`
	ConsumerGroupInstanceId string `` /* 134-byte string literal not displayed */
	Topic                   *Topic `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriberToSubCoordinatorRequest_InitMessage) Descriptor deprecated 

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

Deprecated: Use SubscriberToSubCoordinatorRequest_InitMessage.ProtoReflect.Descriptor instead.

func (*SubscriberToSubCoordinatorRequest_InitMessage) GetConsumerGroup 

func (x *SubscriberToSubCoordinatorRequest_InitMessage) GetConsumerGroup() string

func (*SubscriberToSubCoordinatorRequest_InitMessage) GetConsumerGroupInstanceId 

func (x *SubscriberToSubCoordinatorRequest_InitMessage) GetConsumerGroupInstanceId() string

func (*SubscriberToSubCoordinatorRequest_InitMessage) GetTopic 

func (x *SubscriberToSubCoordinatorRequest_InitMessage) GetTopic() *Topic

func (*SubscriberToSubCoordinatorRequest_InitMessage) ProtoMessage 

func (*SubscriberToSubCoordinatorRequest_InitMessage) ProtoMessage()

func (*SubscriberToSubCoordinatorRequest_InitMessage) ProtoReflect 

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

func (*SubscriberToSubCoordinatorRequest_InitMessage) Reset 

func (x *SubscriberToSubCoordinatorRequest_InitMessage) Reset()

func (*SubscriberToSubCoordinatorRequest_InitMessage) String 

func (x *SubscriberToSubCoordinatorRequest_InitMessage) String() string

type SubscriberToSubCoordinatorResponse 

type SubscriberToSubCoordinatorResponse struct {

	// Types that are assignable to Message:
	//
	//	*SubscriberToSubCoordinatorResponse_Assignment_
	Message isSubscriberToSubCoordinatorResponse_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*SubscriberToSubCoordinatorResponse) Descriptor deprecated 

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

Deprecated: Use SubscriberToSubCoordinatorResponse.ProtoReflect.Descriptor instead.

func (*SubscriberToSubCoordinatorResponse) GetAssignment 

func (x *SubscriberToSubCoordinatorResponse) GetAssignment() *SubscriberToSubCoordinatorResponse_Assignment

func (*SubscriberToSubCoordinatorResponse) GetMessage 

func (m *SubscriberToSubCoordinatorResponse) GetMessage() isSubscriberToSubCoordinatorResponse_Message

func (*SubscriberToSubCoordinatorResponse) ProtoMessage 

func (*SubscriberToSubCoordinatorResponse) ProtoMessage()

func (*SubscriberToSubCoordinatorResponse) ProtoReflect 

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

func (*SubscriberToSubCoordinatorResponse) Reset 

func (x *SubscriberToSubCoordinatorResponse) Reset()

func (*SubscriberToSubCoordinatorResponse) String 

func (x *SubscriberToSubCoordinatorResponse) String() string

type SubscriberToSubCoordinatorResponse_Assignment 

type SubscriberToSubCoordinatorResponse_Assignment struct {
	Generation           int64                        `protobuf:"varint,1,opt,name=generation,proto3" json:"generation,omitempty"`
	PartitionAssignments []*BrokerPartitionAssignment `protobuf:"bytes,2,rep,name=partition_assignments,json=partitionAssignments,proto3" json:"partition_assignments,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriberToSubCoordinatorResponse_Assignment) Descriptor deprecated 

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

Deprecated: Use SubscriberToSubCoordinatorResponse_Assignment.ProtoReflect.Descriptor instead.

func (*SubscriberToSubCoordinatorResponse_Assignment) GetGeneration 

func (x *SubscriberToSubCoordinatorResponse_Assignment) GetGeneration() int64

func (*SubscriberToSubCoordinatorResponse_Assignment) GetPartitionAssignments 

func (x *SubscriberToSubCoordinatorResponse_Assignment) GetPartitionAssignments() []*BrokerPartitionAssignment

func (*SubscriberToSubCoordinatorResponse_Assignment) ProtoMessage 

func (*SubscriberToSubCoordinatorResponse_Assignment) ProtoMessage()

func (*SubscriberToSubCoordinatorResponse_Assignment) ProtoReflect 

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

func (*SubscriberToSubCoordinatorResponse_Assignment) Reset 

func (x *SubscriberToSubCoordinatorResponse_Assignment) Reset()

func (*SubscriberToSubCoordinatorResponse_Assignment) String 

func (x *SubscriberToSubCoordinatorResponse_Assignment) String() string

type SubscriberToSubCoordinatorResponse_Assignment_ 

type SubscriberToSubCoordinatorResponse_Assignment_ struct {
	Assignment *SubscriberToSubCoordinatorResponse_Assignment `protobuf:"bytes,1,opt,name=assignment,proto3,oneof"`
}

type Topic 

type Topic struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// 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) GetNamespace 

func (x *Topic) GetNamespace() string

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect 

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

func (*Topic) Reset 

func (x *Topic) Reset()

func (*Topic) String 

func (x *Topic) String() string

type TopicPartitionStats 

type TopicPartitionStats struct {
	Topic           *Topic     `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition       *Partition `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	PublisherCount  int32      `protobuf:"varint,3,opt,name=publisher_count,json=publisherCount,proto3" json:"publisher_count,omitempty"`
	SubscriberCount int32      `protobuf:"varint,4,opt,name=subscriber_count,json=subscriberCount,proto3" json:"subscriber_count,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicPartitionStats) Descriptor deprecated 

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

Deprecated: Use TopicPartitionStats.ProtoReflect.Descriptor instead.

func (*TopicPartitionStats) GetPartition 

func (x *TopicPartitionStats) GetPartition() *Partition

func (*TopicPartitionStats) GetPublisherCount 

func (x *TopicPartitionStats) GetPublisherCount() int32

func (*TopicPartitionStats) GetSubscriberCount 

func (x *TopicPartitionStats) GetSubscriberCount() int32

func (*TopicPartitionStats) GetTopic 

func (x *TopicPartitionStats) GetTopic() *Topic

func (*TopicPartitionStats) ProtoMessage 

func (*TopicPartitionStats) ProtoMessage()

func (*TopicPartitionStats) ProtoReflect 

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

func (*TopicPartitionStats) Reset 

func (x *TopicPartitionStats) Reset()

func (*TopicPartitionStats) String 

func (x *TopicPartitionStats) String() string

type UnimplementedSeaweedMessagingServer 

type UnimplementedSeaweedMessagingServer struct {
}

UnimplementedSeaweedMessagingServer must be embedded to have forward compatible implementations.

func (UnimplementedSeaweedMessagingServer) AssignTopicPartitions 

func (UnimplementedSeaweedMessagingServer) AssignTopicPartitions(context.Context, *AssignTopicPartitionsRequest) (*AssignTopicPartitionsResponse, error)

func (UnimplementedSeaweedMessagingServer) BalanceTopics 

func (UnimplementedSeaweedMessagingServer) BalanceTopics(context.Context, *BalanceTopicsRequest) (*BalanceTopicsResponse, error)

func (UnimplementedSeaweedMessagingServer) ClosePublishers 

func (UnimplementedSeaweedMessagingServer) ClosePublishers(context.Context, *ClosePublishersRequest) (*ClosePublishersResponse, error)

func (UnimplementedSeaweedMessagingServer) CloseSubscribers 

func (UnimplementedSeaweedMessagingServer) CloseSubscribers(context.Context, *CloseSubscribersRequest) (*CloseSubscribersResponse, error)

func (UnimplementedSeaweedMessagingServer) ConfigureTopic 

func (UnimplementedSeaweedMessagingServer) ConfigureTopic(context.Context, *ConfigureTopicRequest) (*ConfigureTopicResponse, error)

func (UnimplementedSeaweedMessagingServer) FindBrokerLeader 

func (UnimplementedSeaweedMessagingServer) FindBrokerLeader(context.Context, *FindBrokerLeaderRequest) (*FindBrokerLeaderResponse, error)

func (UnimplementedSeaweedMessagingServer) ListTopics 

func (UnimplementedSeaweedMessagingServer) ListTopics(context.Context, *ListTopicsRequest) (*ListTopicsResponse, error)

func (UnimplementedSeaweedMessagingServer) LookupTopicBrokers 

func (UnimplementedSeaweedMessagingServer) LookupTopicBrokers(context.Context, *LookupTopicBrokersRequest) (*LookupTopicBrokersResponse, error)

func (UnimplementedSeaweedMessagingServer) PublishFollowMe 

func (UnimplementedSeaweedMessagingServer) PublishFollowMe(SeaweedMessaging_PublishFollowMeServer) error

func (UnimplementedSeaweedMessagingServer) PublishMessage 

func (UnimplementedSeaweedMessagingServer) PublishMessage(SeaweedMessaging_PublishMessageServer) error

func (UnimplementedSeaweedMessagingServer) PublisherToPubBalancer 

func (UnimplementedSeaweedMessagingServer) PublisherToPubBalancer(SeaweedMessaging_PublisherToPubBalancerServer) error

func (UnimplementedSeaweedMessagingServer) SubscribeMessage 

func (UnimplementedSeaweedMessagingServer) SubscribeMessage(*SubscribeMessageRequest, SeaweedMessaging_SubscribeMessageServer) error

func (UnimplementedSeaweedMessagingServer) SubscriberToSubCoordinator 

func (UnimplementedSeaweedMessagingServer) SubscriberToSubCoordinator(SeaweedMessaging_SubscriberToSubCoordinatorServer) error

type UnsafeSeaweedMessagingServer 

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

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

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.