common

Documentation

Index

• Variables
• type Config
• type ErrFunc
• type MessageHandler
• type MessageHandlerTyped
• type Topic
• type Topics
  • func (t Topics) ToStrings() []string

Variables

var (
	ErrEmptyConfig        = errors.New("err empty config")
	ErrEmptyAddresses     = errors.New("err empty addresses")
	ErrEmptyErrFunc       = errors.New("err empty err func")
	ErrEmptyGroupName     = errors.New("err empty group name")
	ErrGroupAlreadyClosed = errors.New("err group already closed")
	ErrEmptyConsumerGroup = errors.New("err empty consumer group")
	ErrEmptySyncProducer  = errors.New("err empty sync producer")
	ErrEmptyTopics        = errors.New("err empty topics")
	ErrEmptyHandlers      = errors.New("err empty handlers")
	ErrSyncProducerClosed = errors.New("err sync producer closed")
)

Types

type Config

type Config struct {
	Addresses   []string
	SkipErrors  map[Topic]struct{}
	EnableDebug bool
	AppName     string
}

type ErrFunc

type ErrFunc func(err error)

type MessageHandler

type MessageHandler func(msg json.RawMessage) error

type MessageHandlerTyped

type MessageHandlerTyped[T any] func(msg T) error

type Topic

type Topic string

type Topics

type Topics []Topic

func (Topics) ToStrings

func (t Topics) ToStrings() []string