pubsub

Documentation

Index

• type Config
  • func NewConfig() (*Config, error)
• type Kafka
• type Publisher
• type Subscriber

Types

type Config

type Config struct {
	Kafka Kafka `mapstructure:"kafka"`
}

func NewConfig

func NewConfig() (*Config, error)

NewConfig returns a new Config instance.

type Kafka

type Kafka struct {
	BrokerUrls             []string   `mapstructure:"broker_urls"`
	ClientId               string     `mapstructure:"client_id"`
	Cert                   string     `mapstructure:"cert_pem"`
	CertKey                string     `mapstructure:"cert_pem_key"`
	SecurityProtocol       string     `mapstructure:"security_protocol"`
	Publisher              Publisher  `mapstructure:"publisher"`
	Subscriber             Subscriber `mapstructure:"subscriber"`
	SSLVerificationEnabled bool       `mapstructure:"ssl_verification_enabled"`
}

type Publisher

type Publisher struct {
	MaxAttempts  int           `mapstructure:"max_attempts"`
	WriteTimeout time.Duration `mapstructure:"write_timeout"`
	Topic        string        `mapstructure:"topic"`
	Enabled      bool          `mapstructure:"enabled"`
}

type Subscriber

type Subscriber struct {
	Topic   string `mapstructure:"topic"`
	GroupId string `mapstructure:"group_id"`
	Enabled bool   `mapstructure:"enabled"`
}