config

Documentation

Index

• type AuthType
  • func ValidateAuthValue(value string) (AuthType, error)
• type Behaviours
• type Config
  • func (c Config) AuthenticationDisplay() string
  • func (c Config) EncodingDisplay() string
• type EncodingFormat
  • func ValidateEncodingFmtValue(value string) (EncodingFormat, error)
• type ProtoConfig

Types

type AuthType

type AuthType uint

const (
	NoAuth AuthType = iota
	AWSMSKIAM
)

func ValidateAuthValue

func ValidateAuthValue(value string) (AuthType, error)

type Behaviours

type Behaviours struct {
	PersistMessages bool
	SkipMessages    bool
	CommitMessages  bool
}

type Config

type Config struct {
	Name           string
	Authentication AuthType
	Encoding       EncodingFormat
	Brokers        []string
	Topic          string
	ConsumerGroup  string
	Proto          *ProtoConfig
}

func (Config) AuthenticationDisplay

func (c Config) AuthenticationDisplay() string

func (Config) EncodingDisplay

func (c Config) EncodingDisplay() string

type EncodingFormat

type EncodingFormat uint

const (
	JSON EncodingFormat = iota
	Protobuf
	Raw
)

func ValidateEncodingFmtValue

func ValidateEncodingFmtValue(value string) (EncodingFormat, error)

type ProtoConfig

type ProtoConfig struct {
	DescriptorSetFile string
	DescriptorName    string
	MsgDescriptor     protoreflect.MessageDescriptor
}