registry

package
v3.18.1 Latest Latest
Warning

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

 Go to latest Published: May 13, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package registry is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_registry_registry_proto protoreflect.FileDescriptor
View Source 
var Registry_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "registry.Registry",
	HandlerType: (*RegistryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetBrokers",
			Handler:    _Registry_GetBrokers_Handler,
		},
		{
			MethodName: "ListBrokers",
			Handler:    _Registry_ListBrokers_Handler,
		},
		{
			MethodName: "UnmappedBrokers",
			Handler:    _Registry_UnmappedBrokers_Handler,
		},
		{
			MethodName: "GetTopics",
			Handler:    _Registry_GetTopics_Handler,
		},
		{
			MethodName: "ListTopics",
			Handler:    _Registry_ListTopics_Handler,
		},
		{
			MethodName: "CreateTopic",
			Handler:    _Registry_CreateTopic_Handler,
		},
		{
			MethodName: "DeleteTopic",
			Handler:    _Registry_DeleteTopic_Handler,
		},
		{
			MethodName: "ReassigningTopics",
			Handler:    _Registry_ReassigningTopics_Handler,
		},
		{
			MethodName: "UnderReplicatedTopics",
			Handler:    _Registry_UnderReplicatedTopics_Handler,
		},
		{
			MethodName: "TopicMappings",
			Handler:    _Registry_TopicMappings_Handler,
		},
		{
			MethodName: "BrokerMappings",
			Handler:    _Registry_BrokerMappings_Handler,
		},
		{
			MethodName: "TagTopic",
			Handler:    _Registry_TagTopic_Handler,
		},
		{
			MethodName: "DeleteTopicTags",
			Handler:    _Registry_DeleteTopicTags_Handler,
		},
		{
			MethodName: "TagBroker",
			Handler:    _Registry_TagBroker_Handler,
		},
		{
			MethodName: "TagBrokers",
			Handler:    _Registry_TagBrokers_Handler,
		},
		{
			MethodName: "DeleteBrokerTags",
			Handler:    _Registry_DeleteBrokerTags_Handler,
		},
		{
			MethodName: "TranslateOffsets",
			Handler:    _Registry_TranslateOffsets_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "registry/registry.proto",
}

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

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.ServiceRegistrar, 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) Descriptor() ([]byte, []int)

Deprecated: Use Broker.ProtoReflect.Descriptor instead.

func (*Broker) GetEndpoints 

func (x *Broker) GetEndpoints() []string

func (*Broker) GetHost 

func (x *Broker) GetHost() string

func (*Broker) GetId 

func (x *Broker) GetId() uint32

func (*Broker) GetJmxport 

func (x *Broker) GetJmxport() uint32

func (*Broker) GetListenersecurityprotocolmap 

func (x *Broker) GetListenersecurityprotocolmap() map[string]string

func (*Broker) GetPort 

func (x *Broker) GetPort() uint32

func (*Broker) GetRack 

func (x *Broker) GetRack() string

func (*Broker) GetTags 

func (x *Broker) GetTags() map[string]string

func (*Broker) GetTimestamp 

func (x *Broker) GetTimestamp() int64

func (*Broker) GetVersion 

func (x *Broker) GetVersion() uint32

func (*Broker) ProtoMessage 

func (*Broker) ProtoMessage()

func (*Broker) ProtoReflect 

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

func (*Broker) Reset 

func (x *Broker) Reset()

func (*Broker) String 

func (x *Broker) String() string

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"`
	TargetBrokerIds  []uint32 `protobuf:"varint,3,rep,packed,name=target_broker_ids,json=targetBrokerIds,proto3" json:"target_broker_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTopicRequest) Descriptor deprecated 

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

Deprecated: Use CreateTopicRequest.ProtoReflect.Descriptor instead.

func (*CreateTopicRequest) GetTargetBrokerIds added in v3.18.0 

func (x *CreateTopicRequest) GetTargetBrokerIds() []uint32

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) Descriptor() ([]byte, []int)

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

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)
	// TagBrokers takes a TagBrokersRequest and sets any specified tags for the
	// brokers. Any existing tags that are not specified in the request are left
	// unmodified.
	TagBrokers(ctx context.Context, in *TagBrokersRequest, opts ...grpc.CallOption) (*TagBrokersResponse, 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)
	// TagBrokers takes a TagBrokersRequest and sets any specified tags for the
	// brokers. Any existing tags that are not specified in the request are left
	// unmodified.
	TagBrokers(context.Context, *TagBrokersRequest) (*TagBrokersResponse, 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 Replicas added in v3.12.0 

type Replicas struct {
	Ids []uint32 `protobuf:"varint,2,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*Replicas) Descriptor deprecated added in v3.12.0 

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

Deprecated: Use Replicas.ProtoReflect.Descriptor instead.

func (*Replicas) GetIds added in v3.12.0 

func (x *Replicas) GetIds() []uint32

func (*Replicas) ProtoMessage added in v3.12.0 

func (*Replicas) ProtoMessage()

func (*Replicas) ProtoReflect added in v3.12.0 

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

func (*Replicas) Reset added in v3.12.0 

func (x *Replicas) Reset()

func (*Replicas) String added in v3.12.0 

func (x *Replicas) String() string

type TagBrokersRequest added in v3.18.1 

type TagBrokersRequest struct {
	Tags []string `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
	Ids  []uint32 `protobuf:"varint,2,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*TagBrokersRequest) Descriptor deprecated added in v3.18.1 

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

Deprecated: Use TagBrokersRequest.ProtoReflect.Descriptor instead.

func (*TagBrokersRequest) GetIds added in v3.18.1 

func (x *TagBrokersRequest) GetIds() []uint32

func (*TagBrokersRequest) GetTags added in v3.18.1 

func (x *TagBrokersRequest) GetTags() []string

func (*TagBrokersRequest) ProtoMessage added in v3.18.1 

func (*TagBrokersRequest) ProtoMessage()

func (*TagBrokersRequest) ProtoReflect added in v3.18.1 

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

func (*TagBrokersRequest) Reset added in v3.18.1 

func (x *TagBrokersRequest) Reset()

func (*TagBrokersRequest) String added in v3.18.1 

func (x *TagBrokersRequest) String() string

type TagBrokersResponse added in v3.18.1 

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

func (*TagBrokersResponse) Descriptor deprecated added in v3.18.1 

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

Deprecated: Use TagBrokersResponse.ProtoReflect.Descriptor instead.

func (*TagBrokersResponse) ProtoMessage added in v3.18.1 

func (*TagBrokersResponse) ProtoMessage()

func (*TagBrokersResponse) ProtoReflect added in v3.18.1 

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

func (*TagBrokersResponse) Reset added in v3.18.1 

func (x *TagBrokersResponse) Reset()

func (*TagBrokersResponse) String added in v3.18.1 

func (x *TagBrokersResponse) String() string

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 */
	Replicas    map[uint32]*Replicas `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Topic) Descriptor deprecated 

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetConfigs 

func (x *Topic) GetConfigs() map[string]string

func (*Topic) GetName 

func (x *Topic) GetName() string

func (*Topic) GetPartitions 

func (x *Topic) GetPartitions() uint32

func (*Topic) GetReplicas added in v3.12.0 

func (x *Topic) GetReplicas() map[uint32]*Replicas

func (*Topic) GetReplication 

func (x *Topic) GetReplication() uint32

func (*Topic) GetTags 

func (x *Topic) GetTags() map[string]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 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"`
	Spanning     bool     `protobuf:"varint,3,opt,name=spanning,proto3" json:"spanning,omitempty"`
	WithReplicas bool     `protobuf:"varint,4,opt,name=with_replicas,json=withReplicas,proto3" json:"with_replicas,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) GetSpanning added in v3.11.0 

func (x *TopicRequest) GetSpanning() bool

func (*TopicRequest) GetTag 

func (x *TopicRequest) GetTag() []string

func (*TopicRequest) GetWithReplicas added in v3.12.0 

func (x *TopicRequest) GetWithReplicas() bool

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) TagBrokers added in v3.18.1 

func (UnimplementedRegistryServer) TagBrokers(context.Context, *TagBrokersRequest) (*TagBrokersResponse, 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.

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.