Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Instance ¶ added in v1.0.3
type Instance struct { rpc.TopicService // contains filtered or unexported fields }
func NewInstance ¶ added in v1.0.3
func NewInstance(config config.BrokerConfig) *Instance
func (*Instance) CreateTopic ¶ added in v1.0.3
func (s *Instance) CreateTopic(ctx context.Context, request *pb.CreateTopicRequest) (*pb.Empty, error)
CreateTopic : when create topic called, fragment-rebalancing should be triggered
func (*Instance) DeleteTopic ¶ added in v1.0.3
func (s *Instance) DeleteTopic(ctx context.Context, request *pb.TopicRequestWithName) (*pb.Empty, error)
DeleteTopic : when delete topic called, fragment-rebalancing should be triggered
Click to show internal directories.
Click to hide internal directories.