Documentation ¶
Index ¶
Constants ¶
View Source
const ( // DecodeFlagTextValue is a value of output in text format. DecodeFlagTextValue = "text" // DecodeFlagJSONValue is a value of output in json format. DecodeFlagJSONValue = "json" )
Variables ¶
View Source
var ( ErrInvalidOffset = errors.New("invalid offset format") ErrOffsetNotSet = errors.New("offset not set") )
View Source
var ErrMaximumReached = errors.New("maximum message reached")
ErrMaximumReached error if limit reached
Functions ¶
func NewConsumeCmd ¶
func NewListCmd ¶
func NewProduceCmd ¶
func NewRootCmd ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.