Documentation ¶
Overview ¶
Package api is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- 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
- func (*Broker) Descriptor() ([]byte, []int)deprecated
- 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 (*Broker) ProtoMessage()
- func (x *Broker) ProtoReflect() protoreflect.Message
- func (x *Broker) Reset()
- func (x *Broker) String() string
- type BrokerRequest
- func (*BrokerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BrokerRequest) GetId() uint32
- func (x *BrokerRequest) GetTag() []string
- func (*BrokerRequest) ProtoMessage()
- func (x *BrokerRequest) ProtoReflect() protoreflect.Message
- func (x *BrokerRequest) Reset()
- func (x *BrokerRequest) String() string
- type BrokerResponse
- func (*BrokerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BrokerResponse) GetBrokers() map[uint32]*Broker
- func (x *BrokerResponse) GetIds() []uint32
- func (*BrokerResponse) ProtoMessage()
- func (x *BrokerResponse) ProtoReflect() protoreflect.Message
- func (x *BrokerResponse) Reset()
- func (x *BrokerResponse) String() string
- type CreateTopicRequest
- func (*CreateTopicRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTopicRequest) GetTargetBrokerTags() []string
- func (x *CreateTopicRequest) GetTopic() *Topic
- func (*CreateTopicRequest) ProtoMessage()
- func (x *CreateTopicRequest) ProtoReflect() protoreflect.Message
- func (x *CreateTopicRequest) Reset()
- func (x *CreateTopicRequest) String() string
- type Empty
- type OffsetMapping
- func (*OffsetMapping) Descriptor() ([]byte, []int)deprecated
- func (x *OffsetMapping) GetLocalOffset() uint64
- func (x *OffsetMapping) GetUpstreamOffset() uint64
- func (*OffsetMapping) ProtoMessage()
- func (x *OffsetMapping) ProtoReflect() protoreflect.Message
- func (x *OffsetMapping) Reset()
- func (x *OffsetMapping) String() string
- type RegistryClient
- type RegistryServer
- type TagResponse
- type Topic
- func (*Topic) Descriptor() ([]byte, []int)deprecated
- 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 (*Topic) ProtoMessage()
- func (x *Topic) ProtoReflect() protoreflect.Message
- func (x *Topic) Reset()
- func (x *Topic) String() string
- type TopicRequest
- func (*TopicRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TopicRequest) GetName() string
- func (x *TopicRequest) GetTag() []string
- func (*TopicRequest) ProtoMessage()
- func (x *TopicRequest) ProtoReflect() protoreflect.Message
- func (x *TopicRequest) Reset()
- func (x *TopicRequest) String() string
- type TopicResponse
- func (*TopicResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TopicResponse) GetNames() []string
- func (x *TopicResponse) GetTopics() map[string]*Topic
- func (*TopicResponse) ProtoMessage()
- func (x *TopicResponse) ProtoReflect() protoreflect.Message
- func (x *TopicResponse) Reset()
- func (x *TopicResponse) String() string
- type TranslateOffsetRequest
- func (*TranslateOffsetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TranslateOffsetRequest) GetGroupId() string
- func (x *TranslateOffsetRequest) GetRemoteClusterAlias() string
- func (*TranslateOffsetRequest) ProtoMessage()
- func (x *TranslateOffsetRequest) ProtoReflect() protoreflect.Message
- func (x *TranslateOffsetRequest) Reset()
- func (x *TranslateOffsetRequest) String() string
- type TranslateOffsetResponse
- func (*TranslateOffsetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TranslateOffsetResponse) GetOffsets() map[string]*OffsetMapping
- func (*TranslateOffsetResponse) ProtoMessage()
- func (x *TranslateOffsetResponse) ProtoReflect() protoreflect.Message
- func (x *TranslateOffsetResponse) Reset()
- func (x *TranslateOffsetResponse) String() string
- type UnimplementedRegistryServer
- 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
- func (*UnmappedBrokersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnmappedBrokersRequest) GetExclude() []string
- func (*UnmappedBrokersRequest) ProtoMessage()
- func (x *UnmappedBrokersRequest) ProtoReflect() protoreflect.Message
- func (x *UnmappedBrokersRequest) Reset()
- func (x *UnmappedBrokersRequest) String() string
- type UnsafeRegistryServer
Constants ¶
This section is empty.
Variables ¶
var File_api_registry_proto protoreflect.FileDescriptor
Functions ¶
func RegisterRegistryHandler ¶
func RegisterRegistryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterRegistryHandler registers the http handlers for service Registry to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterRegistryHandlerClient ¶
func RegisterRegistryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RegistryClient) error
RegisterRegistryHandlerClient registers the http handlers for service Registry to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RegistryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RegistryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RegistryClient" to call the correct interceptors.
func RegisterRegistryHandlerFromEndpoint ¶
func RegisterRegistryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterRegistryHandlerFromEndpoint is same as RegisterRegistryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterRegistryHandlerServer ¶
func RegisterRegistryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RegistryServer) error
RegisterRegistryHandlerServer registers the http handlers for service Registry to "mux". UnaryRPC :call RegistryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterRegistryHandlerFromEndpoint instead.
func RegisterRegistryServer ¶
func RegisterRegistryServer(s *grpc.Server, srv RegistryServer)
Types ¶
type Broker ¶
type Broker struct { // Registry metadata. Tags map[string]string `` /* 149-byte string literal not displayed */ // Broker metadata from ZooKeeper. Id uint32 `protobuf:"varint,5,opt,name=id,proto3" json:"id,omitempty"` Listenersecurityprotocolmap map[string]string `` /* 195-byte string literal not displayed */ Endpoints []string `protobuf:"bytes,7,rep,name=endpoints,proto3" json:"endpoints,omitempty"` Rack string `protobuf:"bytes,8,opt,name=rack,proto3" json:"rack,omitempty"` Jmxport uint32 `protobuf:"varint,9,opt,name=jmxport,proto3" json:"jmxport,omitempty"` Host string `protobuf:"bytes,10,opt,name=host,proto3" json:"host,omitempty"` Timestamp int64 `protobuf:"varint,11,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Port uint32 `protobuf:"varint,12,opt,name=port,proto3" json:"port,omitempty"` Version uint32 `protobuf:"varint,13,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*Broker) Descriptor
deprecated
func (*Broker) GetEndpoints ¶
func (*Broker) GetJmxport ¶
func (*Broker) GetListenersecurityprotocolmap ¶
func (*Broker) GetTimestamp ¶
func (*Broker) GetVersion ¶
func (*Broker) ProtoMessage ¶
func (*Broker) ProtoMessage()
func (*Broker) ProtoReflect ¶
func (x *Broker) ProtoReflect() protoreflect.Message
type BrokerRequest ¶
type BrokerRequest struct { Tag []string `protobuf:"bytes,1,rep,name=tag,proto3" json:"tag,omitempty"` Id uint32 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*BrokerRequest) Descriptor
deprecated
func (*BrokerRequest) Descriptor() ([]byte, []int)
Deprecated: Use BrokerRequest.ProtoReflect.Descriptor instead.
func (*BrokerRequest) GetId ¶
func (x *BrokerRequest) GetId() uint32
func (*BrokerRequest) GetTag ¶
func (x *BrokerRequest) GetTag() []string
func (*BrokerRequest) ProtoMessage ¶
func (*BrokerRequest) ProtoMessage()
func (*BrokerRequest) ProtoReflect ¶
func (x *BrokerRequest) ProtoReflect() protoreflect.Message
func (*BrokerRequest) Reset ¶
func (x *BrokerRequest) Reset()
func (*BrokerRequest) String ¶
func (x *BrokerRequest) String() string
type BrokerResponse ¶
type BrokerResponse struct { Brokers map[uint32]*Broker `` /* 156-byte string literal not displayed */ Ids []uint32 `protobuf:"varint,6,rep,packed,name=ids,proto3" json:"ids,omitempty"` // contains filtered or unexported fields }
func (*BrokerResponse) Descriptor
deprecated
func (*BrokerResponse) Descriptor() ([]byte, []int)
Deprecated: Use BrokerResponse.ProtoReflect.Descriptor instead.
func (*BrokerResponse) GetBrokers ¶
func (x *BrokerResponse) GetBrokers() map[uint32]*Broker
func (*BrokerResponse) GetIds ¶
func (x *BrokerResponse) GetIds() []uint32
func (*BrokerResponse) ProtoMessage ¶
func (*BrokerResponse) ProtoMessage()
func (*BrokerResponse) ProtoReflect ¶
func (x *BrokerResponse) ProtoReflect() protoreflect.Message
func (*BrokerResponse) Reset ¶
func (x *BrokerResponse) Reset()
func (*BrokerResponse) String ¶
func (x *BrokerResponse) String() string
type CreateTopicRequest ¶
type CreateTopicRequest struct { Topic *Topic `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` TargetBrokerTags []string `protobuf:"bytes,2,rep,name=target_broker_tags,json=targetBrokerTags,proto3" json:"target_broker_tags,omitempty"` // contains filtered or unexported fields }
func (*CreateTopicRequest) Descriptor
deprecated
func (*CreateTopicRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateTopicRequest.ProtoReflect.Descriptor instead.
func (*CreateTopicRequest) GetTargetBrokerTags ¶
func (x *CreateTopicRequest) GetTargetBrokerTags() []string
func (*CreateTopicRequest) GetTopic ¶
func (x *CreateTopicRequest) GetTopic() *Topic
func (*CreateTopicRequest) ProtoMessage ¶
func (*CreateTopicRequest) ProtoMessage()
func (*CreateTopicRequest) ProtoReflect ¶
func (x *CreateTopicRequest) ProtoReflect() protoreflect.Message
func (*CreateTopicRequest) Reset ¶
func (x *CreateTopicRequest) Reset()
func (*CreateTopicRequest) String ¶
func (x *CreateTopicRequest) String() string
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type OffsetMapping ¶
type OffsetMapping struct { UpstreamOffset uint64 `protobuf:"varint,1,opt,name=upstream_offset,json=upstreamOffset,proto3" json:"upstream_offset,omitempty"` LocalOffset uint64 `protobuf:"varint,2,opt,name=local_offset,json=localOffset,proto3" json:"local_offset,omitempty"` // contains filtered or unexported fields }
func (*OffsetMapping) Descriptor
deprecated
func (*OffsetMapping) Descriptor() ([]byte, []int)
Deprecated: Use OffsetMapping.ProtoReflect.Descriptor instead.
func (*OffsetMapping) GetLocalOffset ¶
func (x *OffsetMapping) GetLocalOffset() uint64
func (*OffsetMapping) GetUpstreamOffset ¶
func (x *OffsetMapping) GetUpstreamOffset() uint64
func (*OffsetMapping) ProtoMessage ¶
func (*OffsetMapping) ProtoMessage()
func (*OffsetMapping) ProtoReflect ¶
func (x *OffsetMapping) ProtoReflect() protoreflect.Message
func (*OffsetMapping) Reset ¶
func (x *OffsetMapping) Reset()
func (*OffsetMapping) String ¶
func (x *OffsetMapping) String() string
type RegistryClient ¶
type RegistryClient interface { // GetBrokers returns a BrokerResponse with the brokers field populated // with full broker metadata. If the input BrokerRequest.id field is // non-nil, a single broker is returned matching the ID specified in the // Broker object. Otherwise all brokers are returned, optionally filtered // by any provided BrokerRequest.tags parameters. GetBrokers(ctx context.Context, in *BrokerRequest, opts ...grpc.CallOption) (*BrokerResponse, error) // ListBrokers returns a BrokerResponse with the ids field populated // with broker IDs. If the input BrokerRequest.id field is non-nil, // a single broker ID is returned matching the ID specified in the // Broker object if the broker exists. Otherwise all brokers are returned, // optionally filtered by any provided BrokerRequest.tags parameters. ListBrokers(ctx context.Context, in *BrokerRequest, opts ...grpc.CallOption) (*BrokerResponse, error) // UnmappedBrokers returns a BrokerResponse with the ids field // populated with broker IDs that do not hold any assigned partitions. // Any topic names specified in the UnmappedBrokersRequest exclude field // are ignored. For example, broker 1000 holds no partitions other // than one belonging to the 'test0' topic. If UnmappedBrokers is called // with 'test0' specified as an exclude name, broker 1000 will be returned // in the BrokerResponse as an unmapped broker. UnmappedBrokers(ctx context.Context, in *UnmappedBrokersRequest, opts ...grpc.CallOption) (*BrokerResponse, error) // GetTopics returns a TopicResponse with the topics field populated // with full topic metadata. If the input TopicRequest.name field is // non-nil, a single topic is returned matching the name specified in the // Topic object. Otherwise all topics are returned, optionally filtered // by any provided TopicRequest.tags parameters. GetTopics(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*TopicResponse, error) // ListTopics returns a TopicResponse with the names field populated // with topic names. If the input TopicRequest.name field is non-nil, // a single topic name is returned matching the name specified in the // Topic object if the topic exists. Otherwise all topics are returned, // optionally filtered by any provided TopicRequest.tags parameters. ListTopics(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*TopicResponse, error) // //CreateTopic creates a topic. //Example: //$ curl -XPOST "localhost:8080/v1/topics/create" -d '{ //"topic": { //"name": "mytopic", //"partitions": 32, //"replication": 2, //"tags": {"env":"staging"} //}, //"target_broker_tags": ["pool:tests"] //}' CreateTopic(ctx context.Context, in *CreateTopicRequest, opts ...grpc.CallOption) (*Empty, error) // //DeleteTopic takes a TopicRequest and deletes the topic specified in the //TopicRequest.name field. //Example: //$ curl -XDELETE "localhost:8080/v1/topics/mytopic" DeleteTopic(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*Empty, error) // ReassigningTopics returns a TopicResponse with the names field populated // with topic names of all topics undergoing a reassignment. ReassigningTopics(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TopicResponse, error) // UnderReplicatedTopics returns a TopicResponse with the names field populated // with topic names of all under replicated topics. UnderReplicatedTopics(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TopicResponse, error) // TopicMappings returns a BrokerResponse with the ids field // populated with broker IDs that hold at least one partition // for the requested topic. Both a single topic name or specified in the // TopicRequest.name field. TopicMappings(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*BrokerResponse, error) // BrokerMappings returns a TopicResponse with the names field // populated with topics that the broker holds at least one partition // for the requested broker. The broker is specified in the // BrokerRequest.id field. BrokerMappings(ctx context.Context, in *BrokerRequest, opts ...grpc.CallOption) (*TopicResponse, error) // TagTopic takes a TopicRequest and sets any specified // tags for the named topic. Any existing tags that are // not specified in the request are left unmodified. TagTopic(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*TagResponse, error) // DeleteTopicTags takes a TopicRequest and deletes any // specified tags for the named topic. Tags must be provided // as key names only; "key:value" will not target the tag "key". DeleteTopicTags(ctx context.Context, in *TopicRequest, opts ...grpc.CallOption) (*TagResponse, error) // TagBroker takes a BrokerRequest and sets any specified // tags for the named broker. Any existing tags that are // not specified in the request are left unmodified. TagBroker(ctx context.Context, in *BrokerRequest, opts ...grpc.CallOption) (*TagResponse, error) // DeleteBrokerTags takes a BrokerRequest and deletes any // specified tags for the named broker. Tags must be provided // as key names only; "key:value" will not target the tag "key". DeleteBrokerTags(ctx context.Context, in *BrokerRequest, opts ...grpc.CallOption) (*TagResponse, error) // TranslateOffsets returns a TranslateOffsetResponse with the // the upstream/local offsets for the provided consumer group // populated per topic/partition. // The remote cluster alias and consumer group id are specified // in the TranslateOffsetRequest.remote_cluster_alias and // TranslateOffsetRequest.group_id respectively. TranslateOffsets(ctx context.Context, in *TranslateOffsetRequest, opts ...grpc.CallOption) (*TranslateOffsetResponse, error) }
RegistryClient is the client API for Registry 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 NewRegistryClient ¶
func NewRegistryClient(cc grpc.ClientConnInterface) RegistryClient
type RegistryServer ¶
type RegistryServer interface { // GetBrokers returns a BrokerResponse with the brokers field populated // with full broker metadata. If the input BrokerRequest.id field is // non-nil, a single broker is returned matching the ID specified in the // Broker object. Otherwise all brokers are returned, optionally filtered // by any provided BrokerRequest.tags parameters. GetBrokers(context.Context, *BrokerRequest) (*BrokerResponse, error) // ListBrokers returns a BrokerResponse with the ids field populated // with broker IDs. If the input BrokerRequest.id field is non-nil, // a single broker ID is returned matching the ID specified in the // Broker object if the broker exists. Otherwise all brokers are returned, // optionally filtered by any provided BrokerRequest.tags parameters. ListBrokers(context.Context, *BrokerRequest) (*BrokerResponse, error) // UnmappedBrokers returns a BrokerResponse with the ids field // populated with broker IDs that do not hold any assigned partitions. // Any topic names specified in the UnmappedBrokersRequest exclude field // are ignored. For example, broker 1000 holds no partitions other // than one belonging to the 'test0' topic. If UnmappedBrokers is called // with 'test0' specified as an exclude name, broker 1000 will be returned // in the BrokerResponse as an unmapped broker. UnmappedBrokers(context.Context, *UnmappedBrokersRequest) (*BrokerResponse, error) // GetTopics returns a TopicResponse with the topics field populated // with full topic metadata. If the input TopicRequest.name field is // non-nil, a single topic is returned matching the name specified in the // Topic object. Otherwise all topics are returned, optionally filtered // by any provided TopicRequest.tags parameters. GetTopics(context.Context, *TopicRequest) (*TopicResponse, error) // ListTopics returns a TopicResponse with the names field populated // with topic names. If the input TopicRequest.name field is non-nil, // a single topic name is returned matching the name specified in the // Topic object if the topic exists. Otherwise all topics are returned, // optionally filtered by any provided TopicRequest.tags parameters. ListTopics(context.Context, *TopicRequest) (*TopicResponse, error) // //CreateTopic creates a topic. //Example: //$ curl -XPOST "localhost:8080/v1/topics/create" -d '{ //"topic": { //"name": "mytopic", //"partitions": 32, //"replication": 2, //"tags": {"env":"staging"} //}, //"target_broker_tags": ["pool:tests"] //}' CreateTopic(context.Context, *CreateTopicRequest) (*Empty, error) // //DeleteTopic takes a TopicRequest and deletes the topic specified in the //TopicRequest.name field. //Example: //$ curl -XDELETE "localhost:8080/v1/topics/mytopic" DeleteTopic(context.Context, *TopicRequest) (*Empty, error) // ReassigningTopics returns a TopicResponse with the names field populated // with topic names of all topics undergoing a reassignment. ReassigningTopics(context.Context, *Empty) (*TopicResponse, error) // UnderReplicatedTopics returns a TopicResponse with the names field populated // with topic names of all under replicated topics. UnderReplicatedTopics(context.Context, *Empty) (*TopicResponse, error) // TopicMappings returns a BrokerResponse with the ids field // populated with broker IDs that hold at least one partition // for the requested topic. Both a single topic name or specified in the // TopicRequest.name field. TopicMappings(context.Context, *TopicRequest) (*BrokerResponse, error) // BrokerMappings returns a TopicResponse with the names field // populated with topics that the broker holds at least one partition // for the requested broker. The broker is specified in the // BrokerRequest.id field. BrokerMappings(context.Context, *BrokerRequest) (*TopicResponse, error) // TagTopic takes a TopicRequest and sets any specified // tags for the named topic. Any existing tags that are // not specified in the request are left unmodified. TagTopic(context.Context, *TopicRequest) (*TagResponse, error) // DeleteTopicTags takes a TopicRequest and deletes any // specified tags for the named topic. Tags must be provided // as key names only; "key:value" will not target the tag "key". DeleteTopicTags(context.Context, *TopicRequest) (*TagResponse, error) // TagBroker takes a BrokerRequest and sets any specified // tags for the named broker. Any existing tags that are // not specified in the request are left unmodified. TagBroker(context.Context, *BrokerRequest) (*TagResponse, error) // DeleteBrokerTags takes a BrokerRequest and deletes any // specified tags for the named broker. Tags must be provided // as key names only; "key:value" will not target the tag "key". DeleteBrokerTags(context.Context, *BrokerRequest) (*TagResponse, error) // TranslateOffsets returns a TranslateOffsetResponse with the // the upstream/local offsets for the provided consumer group // populated per topic/partition. // The remote cluster alias and consumer group id are specified // in the TranslateOffsetRequest.remote_cluster_alias and // TranslateOffsetRequest.group_id respectively. TranslateOffsets(context.Context, *TranslateOffsetRequest) (*TranslateOffsetResponse, error) // contains filtered or unexported methods }
RegistryServer is the server API for Registry service. All implementations must embed UnimplementedRegistryServer for forward compatibility
type TagResponse ¶
type TagResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*TagResponse) Descriptor
deprecated
func (*TagResponse) Descriptor() ([]byte, []int)
Deprecated: Use TagResponse.ProtoReflect.Descriptor instead.
func (*TagResponse) GetMessage ¶
func (x *TagResponse) GetMessage() string
func (*TagResponse) ProtoMessage ¶
func (*TagResponse) ProtoMessage()
func (*TagResponse) ProtoReflect ¶
func (x *TagResponse) ProtoReflect() protoreflect.Message
func (*TagResponse) Reset ¶
func (x *TagResponse) Reset()
func (*TagResponse) String ¶
func (x *TagResponse) String() string
type Topic ¶
type Topic struct { // Registry metadata. Tags map[string]string `` /* 149-byte string literal not displayed */ // Topic metadata from ZooKeeper. Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"` Partitions uint32 `protobuf:"varint,6,opt,name=partitions,proto3" json:"partitions,omitempty"` Replication uint32 `protobuf:"varint,7,opt,name=replication,proto3" json:"replication,omitempty"` Configs map[string]string `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Topic) Descriptor
deprecated
func (*Topic) GetConfigs ¶
func (*Topic) GetPartitions ¶
func (*Topic) GetReplication ¶
func (*Topic) ProtoMessage ¶
func (*Topic) ProtoMessage()
func (*Topic) ProtoReflect ¶
func (x *Topic) ProtoReflect() protoreflect.Message
type TopicRequest ¶
type TopicRequest struct { Tag []string `protobuf:"bytes,1,rep,name=tag,proto3" json:"tag,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*TopicRequest) Descriptor
deprecated
func (*TopicRequest) Descriptor() ([]byte, []int)
Deprecated: Use TopicRequest.ProtoReflect.Descriptor instead.
func (*TopicRequest) GetName ¶
func (x *TopicRequest) GetName() string
func (*TopicRequest) GetTag ¶
func (x *TopicRequest) GetTag() []string
func (*TopicRequest) ProtoMessage ¶
func (*TopicRequest) ProtoMessage()
func (*TopicRequest) ProtoReflect ¶
func (x *TopicRequest) ProtoReflect() protoreflect.Message
func (*TopicRequest) Reset ¶
func (x *TopicRequest) Reset()
func (*TopicRequest) String ¶
func (x *TopicRequest) String() string
type TopicResponse ¶
type TopicResponse struct { Topics map[string]*Topic `` /* 153-byte string literal not displayed */ Names []string `protobuf:"bytes,6,rep,name=names,proto3" json:"names,omitempty"` // contains filtered or unexported fields }
func (*TopicResponse) Descriptor
deprecated
func (*TopicResponse) Descriptor() ([]byte, []int)
Deprecated: Use TopicResponse.ProtoReflect.Descriptor instead.
func (*TopicResponse) GetNames ¶
func (x *TopicResponse) GetNames() []string
func (*TopicResponse) GetTopics ¶
func (x *TopicResponse) GetTopics() map[string]*Topic
func (*TopicResponse) ProtoMessage ¶
func (*TopicResponse) ProtoMessage()
func (*TopicResponse) ProtoReflect ¶
func (x *TopicResponse) ProtoReflect() protoreflect.Message
func (*TopicResponse) Reset ¶
func (x *TopicResponse) Reset()
func (*TopicResponse) String ¶
func (x *TopicResponse) String() string
type TranslateOffsetRequest ¶
type TranslateOffsetRequest struct { RemoteClusterAlias string `protobuf:"bytes,1,opt,name=remote_cluster_alias,json=remoteClusterAlias,proto3" json:"remote_cluster_alias,omitempty"` GroupId string `protobuf:"bytes,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"` // contains filtered or unexported fields }
func (*TranslateOffsetRequest) Descriptor
deprecated
func (*TranslateOffsetRequest) Descriptor() ([]byte, []int)
Deprecated: Use TranslateOffsetRequest.ProtoReflect.Descriptor instead.
func (*TranslateOffsetRequest) GetGroupId ¶
func (x *TranslateOffsetRequest) GetGroupId() string
func (*TranslateOffsetRequest) GetRemoteClusterAlias ¶
func (x *TranslateOffsetRequest) GetRemoteClusterAlias() string
func (*TranslateOffsetRequest) ProtoMessage ¶
func (*TranslateOffsetRequest) ProtoMessage()
func (*TranslateOffsetRequest) ProtoReflect ¶
func (x *TranslateOffsetRequest) ProtoReflect() protoreflect.Message
func (*TranslateOffsetRequest) Reset ¶
func (x *TranslateOffsetRequest) Reset()
func (*TranslateOffsetRequest) String ¶
func (x *TranslateOffsetRequest) String() string
type TranslateOffsetResponse ¶
type TranslateOffsetResponse struct { Offsets map[string]*OffsetMapping `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*TranslateOffsetResponse) Descriptor
deprecated
func (*TranslateOffsetResponse) Descriptor() ([]byte, []int)
Deprecated: Use TranslateOffsetResponse.ProtoReflect.Descriptor instead.
func (*TranslateOffsetResponse) GetOffsets ¶
func (x *TranslateOffsetResponse) GetOffsets() map[string]*OffsetMapping
func (*TranslateOffsetResponse) ProtoMessage ¶
func (*TranslateOffsetResponse) ProtoMessage()
func (*TranslateOffsetResponse) ProtoReflect ¶
func (x *TranslateOffsetResponse) ProtoReflect() protoreflect.Message
func (*TranslateOffsetResponse) Reset ¶
func (x *TranslateOffsetResponse) Reset()
func (*TranslateOffsetResponse) String ¶
func (x *TranslateOffsetResponse) String() string
type UnimplementedRegistryServer ¶
type UnimplementedRegistryServer struct { }
UnimplementedRegistryServer must be embedded to have forward compatible implementations.
func (UnimplementedRegistryServer) BrokerMappings ¶
func (UnimplementedRegistryServer) BrokerMappings(context.Context, *BrokerRequest) (*TopicResponse, error)
func (UnimplementedRegistryServer) CreateTopic ¶
func (UnimplementedRegistryServer) CreateTopic(context.Context, *CreateTopicRequest) (*Empty, error)
func (UnimplementedRegistryServer) DeleteBrokerTags ¶
func (UnimplementedRegistryServer) DeleteBrokerTags(context.Context, *BrokerRequest) (*TagResponse, error)
func (UnimplementedRegistryServer) DeleteTopic ¶
func (UnimplementedRegistryServer) DeleteTopic(context.Context, *TopicRequest) (*Empty, error)
func (UnimplementedRegistryServer) DeleteTopicTags ¶
func (UnimplementedRegistryServer) DeleteTopicTags(context.Context, *TopicRequest) (*TagResponse, error)
func (UnimplementedRegistryServer) GetBrokers ¶
func (UnimplementedRegistryServer) GetBrokers(context.Context, *BrokerRequest) (*BrokerResponse, error)
func (UnimplementedRegistryServer) GetTopics ¶
func (UnimplementedRegistryServer) GetTopics(context.Context, *TopicRequest) (*TopicResponse, error)
func (UnimplementedRegistryServer) ListBrokers ¶
func (UnimplementedRegistryServer) ListBrokers(context.Context, *BrokerRequest) (*BrokerResponse, error)
func (UnimplementedRegistryServer) ListTopics ¶
func (UnimplementedRegistryServer) ListTopics(context.Context, *TopicRequest) (*TopicResponse, error)
func (UnimplementedRegistryServer) ReassigningTopics ¶
func (UnimplementedRegistryServer) ReassigningTopics(context.Context, *Empty) (*TopicResponse, error)
func (UnimplementedRegistryServer) TagBroker ¶
func (UnimplementedRegistryServer) TagBroker(context.Context, *BrokerRequest) (*TagResponse, error)
func (UnimplementedRegistryServer) TagTopic ¶
func (UnimplementedRegistryServer) TagTopic(context.Context, *TopicRequest) (*TagResponse, error)
func (UnimplementedRegistryServer) TopicMappings ¶
func (UnimplementedRegistryServer) TopicMappings(context.Context, *TopicRequest) (*BrokerResponse, error)
func (UnimplementedRegistryServer) TranslateOffsets ¶
func (UnimplementedRegistryServer) TranslateOffsets(context.Context, *TranslateOffsetRequest) (*TranslateOffsetResponse, error)
func (UnimplementedRegistryServer) UnderReplicatedTopics ¶
func (UnimplementedRegistryServer) UnderReplicatedTopics(context.Context, *Empty) (*TopicResponse, error)
func (UnimplementedRegistryServer) UnmappedBrokers ¶
func (UnimplementedRegistryServer) UnmappedBrokers(context.Context, *UnmappedBrokersRequest) (*BrokerResponse, error)
type UnmappedBrokersRequest ¶
type UnmappedBrokersRequest struct { Exclude []string `protobuf:"bytes,1,rep,name=exclude,proto3" json:"exclude,omitempty"` // contains filtered or unexported fields }
func (*UnmappedBrokersRequest) Descriptor
deprecated
func (*UnmappedBrokersRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnmappedBrokersRequest.ProtoReflect.Descriptor instead.
func (*UnmappedBrokersRequest) GetExclude ¶
func (x *UnmappedBrokersRequest) GetExclude() []string
func (*UnmappedBrokersRequest) ProtoMessage ¶
func (*UnmappedBrokersRequest) ProtoMessage()
func (*UnmappedBrokersRequest) ProtoReflect ¶
func (x *UnmappedBrokersRequest) ProtoReflect() protoreflect.Message
func (*UnmappedBrokersRequest) Reset ¶
func (x *UnmappedBrokersRequest) Reset()
func (*UnmappedBrokersRequest) String ¶
func (x *UnmappedBrokersRequest) String() string
type UnsafeRegistryServer ¶
type UnsafeRegistryServer interface {
// contains filtered or unexported methods
}
UnsafeRegistryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RegistryServer will result in compilation errors.