Documentation ¶
Index ¶
- func Append(mrAddrs []string, clusterID types.ClusterID, topicID types.TopicID, ...) error
- func AppendTo(mrAddrs []string, clusterID types.ClusterID, topicID types.TopicID, ...) error
- func Subscribe(mrAddrs []string, clusterID types.ClusterID, topicID types.TopicID) error
- func SubscribeTo(mrAddrs []string, clusterID types.ClusterID, topicID types.TopicID, ...) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SubscribeTo ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.