config

package
v1.1.0 Latest Latest
Warning

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

Go to latest
Published: Jan 27, 2025 License: MIT Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v1.1.0

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

Jump to

Keyboard shortcuts

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