Documentation
¶
Index ¶
- func CloseClient() error
- func InitClient(addr string) error
- func LoopConsume(ctx context.Context, topic, group, clientId string, handler consumeFunc) error
- func Pub(ctx context.Context, req *omega.PubReq) (*omega.Response, error)
- func Sub(ctx context.Context, req *omega.SubReq) (*omega.SubRsp, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CloseClient ¶
func CloseClient() error
func InitClient ¶
func LoopConsume ¶
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.