message

Documentation

Index

• type Cfg
• type DSNConnection
• type Message
  • func Open(brokers []string, opts ...Opts) (*Message, error)
• type Opts
  • func Config(cfg Cfg) Opts

Types

type Cfg

type Cfg struct {
	Username    string
	Password    string
	Sasl        bool
	WorkerCount int
	BatchSize   int
	Topics      []string
	GroupID     string
	Conn        DSNConnection
}

type DSNConnection

type DSNConnection struct {
	Host string
	Port string
	User string
	Pass string
	Name string
}

type Message

type Message struct {
	Outbox *outbox.Outbox
	Inbox  *inbox.Inbox
	// contains filtered or unexported fields
}

func Open

func Open(brokers []string, opts ...Opts) (*Message, error)

type Opts

type Opts func(*Message) error

func Config

func Config(cfg Cfg) Opts