cmd

package
v0.0.0-...-11052b5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 23, 2024 License: Apache-2.0 Imports: 30 Imported by: 0

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 Execute

func Execute()

func NewConsumeCmd

func NewConsumeCmd() *cobra.Command

func NewListCmd

func NewListCmd() *cobra.Command

func NewProduceCmd

func NewProduceCmd() *cobra.Command

func NewRootCmd

func NewRootCmd() *cobra.Command

Types

type Flags

type Flags struct {
	Config    string
	Partition int32
	// contains filtered or unexported fields
}

func NewFlags

func NewFlags(parent *cobra.Command) *Flags

func (*Flags) Init

func (f *Flags) Init()

func (*Flags) Prepare

func (f *Flags) Prepare() (err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL