common

Documentation

Index

• Variables
• type Config
• type ErrFunc
• type MessageHandler
• 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")
)

Types

type Config

type Config struct {
	Addresses           []string
	SkipUnmarshalErrors map[Topic]struct{}
}

type ErrFunc

type ErrFunc func(err error)

type MessageHandler

type MessageHandler func(msg json.RawMessage) error

type Topic

type Topic string

type Topics

type Topics []Topic

func (Topics) ToStrings

func (t Topics) ToStrings() []string