Versions in this module Expand all Collapse all v0 v0.0.71 Dec 23, 2019 Changes in this version + func Benchmark(ctx context.Context, config *viper.Viper) *cobra.Command + func ConsumeStream(ctx context.Context, config *viper.Viper) *cobra.Command + func CreateStream(ctx context.Context, config *viper.Viper) *cobra.Command + func ListStreams(ctx context.Context, config *viper.Viper) *cobra.Command + func PutMessageInStream(ctx context.Context, config *viper.Viper) *cobra.Command + func ReadStream(ctx context.Context, config *viper.Viper) *cobra.Command + func ReadStreamStatistics(ctx context.Context, config *viper.Viper) *cobra.Command + func Register(ctx context.Context, cmd *cobra.Command, config *viper.Viper) + func Stream(ctx context.Context, config *viper.Viper) *cobra.Command