Versions in this module Expand all Collapse all v3 v3.9.1 Jun 4, 2021 v3.9.0 Jun 3, 2021 Changes in this version + var File_api_registry_proto protoreflect.FileDescriptor + func RegisterRegistryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterRegistryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RegistryClient) error + func RegisterRegistryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterRegistryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RegistryServer) error + func RegisterRegistryServer(s *grpc.Server, srv RegistryServer) + type Broker struct + Endpoints []string + Host string + Id uint32 + Jmxport uint32 + Listenersecurityprotocolmap map[string]string + Port uint32 + Rack string + Tags map[string]string + Timestamp int64 + Version uint32 + func (*Broker) Descriptor() ([]byte, []int) + func (*Broker) ProtoMessage() + func (x *Broker) GetEndpoints() []string + func (x *Broker) GetHost() string + func (x *Broker) GetId() uint32 + func (x *Broker) GetJmxport() uint32 + func (x *Broker) GetListenersecurityprotocolmap() map[string]string + func (x *Broker) GetPort() uint32 + func (x *Broker) GetRack() string + func (x *Broker) GetTags() map[string]string + func (x *Broker) GetTimestamp() int64 + func (x *Broker) GetVersion() uint32 + func (x *Broker) ProtoReflect() protoreflect.Message + func (x *Broker) Reset() + func (x *Broker) String() string + type BrokerRequest struct + Id uint32 + Tag []string + func (*BrokerRequest) Descriptor() ([]byte, []int) + func (*BrokerRequest) ProtoMessage() + func (x *BrokerRequest) GetId() uint32 + func (x *BrokerRequest) GetTag() []string + func (x *BrokerRequest) ProtoReflect() protoreflect.Message + func (x *BrokerRequest) Reset() + func (x *BrokerRequest) String() string + type BrokerResponse struct + Brokers map[uint32]*Broker + Ids []uint32 + func (*BrokerResponse) Descriptor() ([]byte, []int) + func (*BrokerResponse) ProtoMessage() + func (x *BrokerResponse) GetBrokers() map[uint32]*Broker + func (x *BrokerResponse) GetIds() []uint32 + func (x *BrokerResponse) ProtoReflect() protoreflect.Message + func (x *BrokerResponse) Reset() + func (x *BrokerResponse) String() string + type CreateTopicRequest struct + TargetBrokerTags []string + Topic *Topic + func (*CreateTopicRequest) Descriptor() ([]byte, []int) + func (*CreateTopicRequest) ProtoMessage() + func (x *CreateTopicRequest) GetTargetBrokerTags() []string + func (x *CreateTopicRequest) GetTopic() *Topic + func (x *CreateTopicRequest) ProtoReflect() protoreflect.Message + func (x *CreateTopicRequest) Reset() + func (x *CreateTopicRequest) String() string + type Empty struct + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (x *Empty) ProtoReflect() protoreflect.Message + func (x *Empty) Reset() + func (x *Empty) String() string + type OffsetMapping struct + LocalOffset uint64 + UpstreamOffset uint64 + func (*OffsetMapping) Descriptor() ([]byte, []int) + func (*OffsetMapping) ProtoMessage() + func (x *OffsetMapping) GetLocalOffset() uint64 + func (x *OffsetMapping) GetUpstreamOffset() uint64 + func (x *OffsetMapping) ProtoReflect() protoreflect.Message + func (x *OffsetMapping) Reset() + func (x *OffsetMapping) String() string + type RegistryClient interface + BrokerMappings func(ctx context.Context, in *BrokerRequest, opts ...grpc.CallOption) (*TopicResponse, error) + CreateTopic func(ctx context.Context, in *CreateTopicRequest, opts ...grpc.CallOption) (*Empty, error) + DeleteBrokerTags func(ctx context.Context, in *BrokerRequest, opts ...grpc.CallOption) (*TagResponse, error) + DeleteTopic func(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*Empty, error) + DeleteTopicTags func(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*TagResponse, error) + GetBrokers func(ctx context.Context, in *BrokerRequest, opts ...grpc.CallOption) (*BrokerResponse, error) + GetTopics func(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*TopicResponse, error) + ListBrokers func(ctx context.Context, in *BrokerRequest, opts ...grpc.CallOption) (*BrokerResponse, error) + ListTopics func(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*TopicResponse, error) + ReassigningTopics func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TopicResponse, error) + TagBroker func(ctx context.Context, in *BrokerRequest, opts ...grpc.CallOption) (*TagResponse, error) + TagTopic func(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*TagResponse, error) + TopicMappings func(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*BrokerResponse, error) + TranslateOffsets func(ctx context.Context, in *TranslateOffsetRequest, opts ...grpc.CallOption) (*TranslateOffsetResponse, error) + UnderReplicatedTopics func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TopicResponse, error) + UnmappedBrokers func(ctx context.Context, in *UnmappedBrokersRequest, opts ...grpc.CallOption) (*BrokerResponse, error) + func NewRegistryClient(cc grpc.ClientConnInterface) RegistryClient + type RegistryServer interface + BrokerMappings func(context.Context, *BrokerRequest) (*TopicResponse, error) + CreateTopic func(context.Context, *CreateTopicRequest) (*Empty, error) + DeleteBrokerTags func(context.Context, *BrokerRequest) (*TagResponse, error) + DeleteTopic func(context.Context, *TopicRequest) (*Empty, error) + DeleteTopicTags func(context.Context, *TopicRequest) (*TagResponse, error) + GetBrokers func(context.Context, *BrokerRequest) (*BrokerResponse, error) + GetTopics func(context.Context, *TopicRequest) (*TopicResponse, error) + ListBrokers func(context.Context, *BrokerRequest) (*BrokerResponse, error) + ListTopics func(context.Context, *TopicRequest) (*TopicResponse, error) + ReassigningTopics func(context.Context, *Empty) (*TopicResponse, error) + TagBroker func(context.Context, *BrokerRequest) (*TagResponse, error) + TagTopic func(context.Context, *TopicRequest) (*TagResponse, error) + TopicMappings func(context.Context, *TopicRequest) (*BrokerResponse, error) + TranslateOffsets func(context.Context, *TranslateOffsetRequest) (*TranslateOffsetResponse, error) + UnderReplicatedTopics func(context.Context, *Empty) (*TopicResponse, error) + UnmappedBrokers func(context.Context, *UnmappedBrokersRequest) (*BrokerResponse, error) + type TagResponse struct + Message string + func (*TagResponse) Descriptor() ([]byte, []int) + func (*TagResponse) ProtoMessage() + func (x *TagResponse) GetMessage() string + func (x *TagResponse) ProtoReflect() protoreflect.Message + func (x *TagResponse) Reset() + func (x *TagResponse) String() string + type Topic struct + Configs map[string]string + Name string + Partitions uint32 + Replication uint32 + Tags map[string]string + func (*Topic) Descriptor() ([]byte, []int) + func (*Topic) ProtoMessage() + func (x *Topic) GetConfigs() map[string]string + func (x *Topic) GetName() string + func (x *Topic) GetPartitions() uint32 + func (x *Topic) GetReplication() uint32 + func (x *Topic) GetTags() map[string]string + func (x *Topic) ProtoReflect() protoreflect.Message + func (x *Topic) Reset() + func (x *Topic) String() string + type TopicRequest struct + Name string + Tag []string + func (*TopicRequest) Descriptor() ([]byte, []int) + func (*TopicRequest) ProtoMessage() + func (x *TopicRequest) GetName() string + func (x *TopicRequest) GetTag() []string + func (x *TopicRequest) ProtoReflect() protoreflect.Message + func (x *TopicRequest) Reset() + func (x *TopicRequest) String() string + type TopicResponse struct + Names []string + Topics map[string]*Topic + func (*TopicResponse) Descriptor() ([]byte, []int) + func (*TopicResponse) ProtoMessage() + func (x *TopicResponse) GetNames() []string + func (x *TopicResponse) GetTopics() map[string]*Topic + func (x *TopicResponse) ProtoReflect() protoreflect.Message + func (x *TopicResponse) Reset() + func (x *TopicResponse) String() string + type TranslateOffsetRequest struct + GroupId string + RemoteClusterAlias string + func (*TranslateOffsetRequest) Descriptor() ([]byte, []int) + func (*TranslateOffsetRequest) ProtoMessage() + func (x *TranslateOffsetRequest) GetGroupId() string + func (x *TranslateOffsetRequest) GetRemoteClusterAlias() string + func (x *TranslateOffsetRequest) ProtoReflect() protoreflect.Message + func (x *TranslateOffsetRequest) Reset() + func (x *TranslateOffsetRequest) String() string + type TranslateOffsetResponse struct + Offsets map[string]*OffsetMapping + func (*TranslateOffsetResponse) Descriptor() ([]byte, []int) + func (*TranslateOffsetResponse) ProtoMessage() + func (x *TranslateOffsetResponse) GetOffsets() map[string]*OffsetMapping + func (x *TranslateOffsetResponse) ProtoReflect() protoreflect.Message + func (x *TranslateOffsetResponse) Reset() + func (x *TranslateOffsetResponse) String() string + type UnimplementedRegistryServer struct + func (UnimplementedRegistryServer) BrokerMappings(context.Context, *BrokerRequest) (*TopicResponse, error) + func (UnimplementedRegistryServer) CreateTopic(context.Context, *CreateTopicRequest) (*Empty, error) + func (UnimplementedRegistryServer) DeleteBrokerTags(context.Context, *BrokerRequest) (*TagResponse, error) + func (UnimplementedRegistryServer) DeleteTopic(context.Context, *TopicRequest) (*Empty, error) + func (UnimplementedRegistryServer) DeleteTopicTags(context.Context, *TopicRequest) (*TagResponse, error) + func (UnimplementedRegistryServer) GetBrokers(context.Context, *BrokerRequest) (*BrokerResponse, error) + func (UnimplementedRegistryServer) GetTopics(context.Context, *TopicRequest) (*TopicResponse, error) + func (UnimplementedRegistryServer) ListBrokers(context.Context, *BrokerRequest) (*BrokerResponse, error) + func (UnimplementedRegistryServer) ListTopics(context.Context, *TopicRequest) (*TopicResponse, error) + func (UnimplementedRegistryServer) ReassigningTopics(context.Context, *Empty) (*TopicResponse, error) + func (UnimplementedRegistryServer) TagBroker(context.Context, *BrokerRequest) (*TagResponse, error) + func (UnimplementedRegistryServer) TagTopic(context.Context, *TopicRequest) (*TagResponse, error) + func (UnimplementedRegistryServer) TopicMappings(context.Context, *TopicRequest) (*BrokerResponse, error) + func (UnimplementedRegistryServer) TranslateOffsets(context.Context, *TranslateOffsetRequest) (*TranslateOffsetResponse, error) + func (UnimplementedRegistryServer) UnderReplicatedTopics(context.Context, *Empty) (*TopicResponse, error) + func (UnimplementedRegistryServer) UnmappedBrokers(context.Context, *UnmappedBrokersRequest) (*BrokerResponse, error) + type UnmappedBrokersRequest struct + Exclude []string + func (*UnmappedBrokersRequest) Descriptor() ([]byte, []int) + func (*UnmappedBrokersRequest) ProtoMessage() + func (x *UnmappedBrokersRequest) GetExclude() []string + func (x *UnmappedBrokersRequest) ProtoReflect() protoreflect.Message + func (x *UnmappedBrokersRequest) Reset() + func (x *UnmappedBrokersRequest) String() string + type UnsafeRegistryServer interface
Go to main page