varlogcli

func Append(mrAddrs []string, clusterID types.ClusterID, topicID types.TopicID, batchSize int) error

func AppendStress(snAddr string, tpid types.TopicID, lsid types.LogStreamID, msgSize, batchSize, concurrency, appendCount int) error

func AppendTo(mrAddrs []string, clusterID types.ClusterID, topicID types.TopicID, logStreamID types.LogStreamID, batchSize int) error

func Subscribe(mrAddrs []string, clusterID types.ClusterID, topicID types.TopicID) error

func SubscribeTo(mrAddrs []string, clusterID types.ClusterID, topicID types.TopicID, logStreamID types.LogStreamID) (err error)