groupcmdutil

Documentation

Index

• Constants
• Variables
• type Validator
  • func (v *Validator) ValidateOffset(offset string) error
  • func (v *Validator) ValidateOffsetValue(offset string, value string) error

Constants

const (
	OffsetAbsolute  = string(kafkainstanceclient.OFFSETTYPE_ABSOLUTE)
	OffsetEarliest  = string(kafkainstanceclient.OFFSETTYPE_EARLIEST)
	OffsetTimestamp = string(kafkainstanceclient.OFFSETTYPE_TIMESTAMP)
	OffsetLatest    = string(kafkainstanceclient.OFFSETTYPE_LATEST)
)

valid values for consumer group reset offset operaion

Variables

var ValidOffsets = []string{OffsetAbsolute, OffsetEarliest, OffsetTimestamp, OffsetLatest}

Types

type Validator

type Validator struct {
	Localizer localize.Localizer
}

func (*Validator) ValidateOffset

func (v *Validator) ValidateOffset(offset string) error

ValidateOffset checks if value v is a valid value for --offset

func (*Validator) ValidateOffsetValue

func (v *Validator) ValidateOffsetValue(offset string, value string) error

ValidateOffsetValue validates value for timestamp and absolute offset value for absolute offset should be integer and timestamp should be in format "yyyy-MM-dd'T'HH:mm:ssz"