Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateAdminCtx ¶
func CreateTopic ¶
func CreateTopic(bc *stgbroker.BrokerController, ctx netm.Context, topicConfigOld *stgcommon.TopicConfig, newTopic string) (*protocol.RemotingCommand, error)
func ProcessRequest ¶
func ProcessRequest(bc *stgbroker.BrokerController, ctx netm.Context, code int32, requestHeader protocol.CommandCustomHeader) (*protocol.RemotingCommand, error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.