infrastructure

Documentation

Index

• func Boot(ctx context.Context) (<-chan struct{}, error)
• func GetLogger() *zerolog.Logger
• type PubSub
  • func GetPubSub() *PubSub
• type PubSubConfig

Functions

func Boot

func Boot(ctx context.Context) (<-chan struct{}, error)

Prepares infrastructure layer

func GetLogger

func GetLogger() *zerolog.Logger

Types

type PubSub

type PubSub struct {
	message.Publisher
	message.Subscriber
}

func GetPubSub

func GetPubSub() *PubSub

type PubSubConfig

type PubSubConfig struct {
	SaramaConfig  *sarama.Config
	Brokers       []string `config:"pub-sub-brokers,required"`
	ConsumerGroup string   `config:"pub-sub-consumer-group"`
}