internal

Documentation

Index

• func Errorf(format string, a ...interface{}) error
• func GetBrokers() []string
• func LoadENVFiles() error
• func New(msg string) error
• func NewPublisher(logger watermill.LoggerAdapter) (message.Publisher, error)
• func NewSubscriber(consumerGroup string, logger watermill.LoggerAdapter) (message.Subscriber, error)
• func Wrap(orig error, msg string) error
• func Wrapf(orig error, format string, a ...interface{}) error
• type Error
  • func (e *Error) Error() string
  • func (e *Error) Unwrap() error

Functions

func Errorf

func Errorf(format string, a ...interface{}) error

func GetBrokers

func GetBrokers() []string

func LoadENVFiles

func LoadENVFiles() error

func New

func New(msg string) error

func NewPublisher

func NewPublisher(logger watermill.LoggerAdapter) (message.Publisher, error)

func NewSubscriber

func NewSubscriber(consumerGroup string, logger watermill.LoggerAdapter) (message.Subscriber, error)

func Wrap

func Wrap(orig error, msg string) error

func Wrapf

func Wrapf(orig error, format string, a ...interface{}) error

Types

type Error

type Error struct {
	// contains filtered or unexported fields
}

func (*Error) Error

func (e *Error) Error() string

func (*Error) Unwrap

func (e *Error) Unwrap() error