Versions in this module Expand all Collapse all v1 v1.5.0 Jan 30, 2026 v1.4.2 Jan 19, 2026 Changes in this version + const AssignmentStream_WatchAssignments_FullMethodName + const BrokerControl_DrainPartitions_FullMethodName + const BrokerControl_GetStatus_FullMethodName + const BrokerControl_StreamMetrics_FullMethodName + const BrokerControl_TriggerFlush_FullMethodName + var AssignmentStream_ServiceDesc = grpc.ServiceDesc + var BrokerControl_ServiceDesc = grpc.ServiceDesc + var File_control_broker_proto protoreflect.FileDescriptor + func RegisterAssignmentStreamServer(s grpc.ServiceRegistrar, srv AssignmentStreamServer) + func RegisterBrokerControlServer(s grpc.ServiceRegistrar, srv BrokerControlServer) + type Ack struct + Message string + func (*Ack) Descriptor() ([]byte, []int) + func (*Ack) ProtoMessage() + func (x *Ack) GetMessage() string + func (x *Ack) ProtoReflect() protoreflect.Message + func (x *Ack) Reset() + func (x *Ack) String() string + type AssignmentStreamClient interface + WatchAssignments func(ctx context.Context, in *AssignmentWatchRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[PartitionAssignmentEvent], error) + func NewAssignmentStreamClient(cc grpc.ClientConnInterface) AssignmentStreamClient + type AssignmentStreamServer interface + WatchAssignments func(*AssignmentWatchRequest, grpc.ServerStreamingServer[PartitionAssignmentEvent]) error + type AssignmentStream_WatchAssignmentsClient = grpc.ServerStreamingClient[PartitionAssignmentEvent] + type AssignmentStream_WatchAssignmentsServer = grpc.ServerStreamingServer[PartitionAssignmentEvent] + type AssignmentWatchRequest struct + BrokerId string + func (*AssignmentWatchRequest) Descriptor() ([]byte, []int) + func (*AssignmentWatchRequest) ProtoMessage() + func (x *AssignmentWatchRequest) GetBrokerId() string + func (x *AssignmentWatchRequest) ProtoReflect() protoreflect.Message + func (x *AssignmentWatchRequest) Reset() + func (x *AssignmentWatchRequest) String() string + type BrokerControlClient interface + DrainPartitions func(ctx context.Context, in *DrainPartitionsRequest, opts ...grpc.CallOption) (*DrainPartitionsResponse, error) + GetStatus func(ctx context.Context, in *BrokerStatusRequest, opts ...grpc.CallOption) (*BrokerStatusResponse, error) + StreamMetrics func(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[MetricsSample, Ack], error) + TriggerFlush func(ctx context.Context, in *TriggerFlushRequest, opts ...grpc.CallOption) (*TriggerFlushResponse, error) + func NewBrokerControlClient(cc grpc.ClientConnInterface) BrokerControlClient + type BrokerControlServer interface + DrainPartitions func(context.Context, *DrainPartitionsRequest) (*DrainPartitionsResponse, error) + GetStatus func(context.Context, *BrokerStatusRequest) (*BrokerStatusResponse, error) + StreamMetrics func(grpc.ClientStreamingServer[MetricsSample, Ack]) error + TriggerFlush func(context.Context, *TriggerFlushRequest) (*TriggerFlushResponse, error) + type BrokerControl_StreamMetricsClient = grpc.ClientStreamingClient[MetricsSample, Ack] + type BrokerControl_StreamMetricsServer = grpc.ClientStreamingServer[MetricsSample, Ack] + type BrokerStatusRequest struct + func (*BrokerStatusRequest) Descriptor() ([]byte, []int) + func (*BrokerStatusRequest) ProtoMessage() + func (x *BrokerStatusRequest) ProtoReflect() protoreflect.Message + func (x *BrokerStatusRequest) Reset() + func (x *BrokerStatusRequest) String() string + type BrokerStatusResponse struct + BrokerId string + Partitions []*PartitionStatus + Ready bool + Version string + func (*BrokerStatusResponse) Descriptor() ([]byte, []int) + func (*BrokerStatusResponse) ProtoMessage() + func (x *BrokerStatusResponse) GetBrokerId() string + func (x *BrokerStatusResponse) GetPartitions() []*PartitionStatus + func (x *BrokerStatusResponse) GetReady() bool + func (x *BrokerStatusResponse) GetVersion() string + func (x *BrokerStatusResponse) ProtoReflect() protoreflect.Message + func (x *BrokerStatusResponse) Reset() + func (x *BrokerStatusResponse) String() string + type DrainPartitionsRequest struct + DeadlineSeconds int32 + Partitions []*PartitionRef + Reason string + func (*DrainPartitionsRequest) Descriptor() ([]byte, []int) + func (*DrainPartitionsRequest) ProtoMessage() + func (x *DrainPartitionsRequest) GetDeadlineSeconds() int32 + func (x *DrainPartitionsRequest) GetPartitions() []*PartitionRef + func (x *DrainPartitionsRequest) GetReason() string + func (x *DrainPartitionsRequest) ProtoReflect() protoreflect.Message + func (x *DrainPartitionsRequest) Reset() + func (x *DrainPartitionsRequest) String() string + type DrainPartitionsResponse struct + Drained []*PartitionRef + Pending []*PartitionRef + func (*DrainPartitionsResponse) Descriptor() ([]byte, []int) + func (*DrainPartitionsResponse) ProtoMessage() + func (x *DrainPartitionsResponse) GetDrained() []*PartitionRef + func (x *DrainPartitionsResponse) GetPending() []*PartitionRef + func (x *DrainPartitionsResponse) ProtoReflect() protoreflect.Message + func (x *DrainPartitionsResponse) Reset() + func (x *DrainPartitionsResponse) String() string + type MetricsSample struct + BrokerId string + Counters map[string]float64 + Gauges map[string]float64 + TimestampMs int64 + func (*MetricsSample) Descriptor() ([]byte, []int) + func (*MetricsSample) ProtoMessage() + func (x *MetricsSample) GetBrokerId() string + func (x *MetricsSample) GetCounters() map[string]float64 + func (x *MetricsSample) GetGauges() map[string]float64 + func (x *MetricsSample) GetTimestampMs() int64 + func (x *MetricsSample) ProtoReflect() protoreflect.Message + func (x *MetricsSample) Reset() + func (x *MetricsSample) String() string + type PartitionAssignmentEvent struct + BrokerId string + Epoch int32 + Partition *PartitionRef + Status string + func (*PartitionAssignmentEvent) Descriptor() ([]byte, []int) + func (*PartitionAssignmentEvent) ProtoMessage() + func (x *PartitionAssignmentEvent) GetBrokerId() string + func (x *PartitionAssignmentEvent) GetEpoch() int32 + func (x *PartitionAssignmentEvent) GetPartition() *PartitionRef + func (x *PartitionAssignmentEvent) GetStatus() string + func (x *PartitionAssignmentEvent) ProtoReflect() protoreflect.Message + func (x *PartitionAssignmentEvent) Reset() + func (x *PartitionAssignmentEvent) String() string + type PartitionRef struct + Partition int32 + Topic string + func (*PartitionRef) Descriptor() ([]byte, []int) + func (*PartitionRef) ProtoMessage() + func (x *PartitionRef) GetPartition() int32 + func (x *PartitionRef) GetTopic() string + func (x *PartitionRef) ProtoReflect() protoreflect.Message + func (x *PartitionRef) Reset() + func (x *PartitionRef) String() string + type PartitionStatus struct + HighWatermark int64 + Leader bool + LogEndOffset int64 + LogStartOffset int64 + Partition int32 + State string + Topic string + func (*PartitionStatus) Descriptor() ([]byte, []int) + func (*PartitionStatus) ProtoMessage() + func (x *PartitionStatus) GetHighWatermark() int64 + func (x *PartitionStatus) GetLeader() bool + func (x *PartitionStatus) GetLogEndOffset() int64 + func (x *PartitionStatus) GetLogStartOffset() int64 + func (x *PartitionStatus) GetPartition() int32 + func (x *PartitionStatus) GetState() string + func (x *PartitionStatus) GetTopic() string + func (x *PartitionStatus) ProtoReflect() protoreflect.Message + func (x *PartitionStatus) Reset() + func (x *PartitionStatus) String() string + type TriggerFlushRequest struct + AllAssigned bool + Partitions []*PartitionRef + func (*TriggerFlushRequest) Descriptor() ([]byte, []int) + func (*TriggerFlushRequest) ProtoMessage() + func (x *TriggerFlushRequest) GetAllAssigned() bool + func (x *TriggerFlushRequest) GetPartitions() []*PartitionRef + func (x *TriggerFlushRequest) ProtoReflect() protoreflect.Message + func (x *TriggerFlushRequest) Reset() + func (x *TriggerFlushRequest) String() string + type TriggerFlushResponse struct + Flushed []*PartitionRef + func (*TriggerFlushResponse) Descriptor() ([]byte, []int) + func (*TriggerFlushResponse) ProtoMessage() + func (x *TriggerFlushResponse) GetFlushed() []*PartitionRef + func (x *TriggerFlushResponse) ProtoReflect() protoreflect.Message + func (x *TriggerFlushResponse) Reset() + func (x *TriggerFlushResponse) String() string + type UnimplementedAssignmentStreamServer struct + func (UnimplementedAssignmentStreamServer) WatchAssignments(*AssignmentWatchRequest, grpc.ServerStreamingServer[PartitionAssignmentEvent]) error + type UnimplementedBrokerControlServer struct + func (UnimplementedBrokerControlServer) DrainPartitions(context.Context, *DrainPartitionsRequest) (*DrainPartitionsResponse, error) + func (UnimplementedBrokerControlServer) GetStatus(context.Context, *BrokerStatusRequest) (*BrokerStatusResponse, error) + func (UnimplementedBrokerControlServer) StreamMetrics(grpc.ClientStreamingServer[MetricsSample, Ack]) error + func (UnimplementedBrokerControlServer) TriggerFlush(context.Context, *TriggerFlushRequest) (*TriggerFlushResponse, error) + type UnsafeAssignmentStreamServer interface + type UnsafeBrokerControlServer interface
Go to main page