utilities

Documentation

Index

• func ConnectMongo(uri string, maxRetries int, retryDelay time.Duration) (*mongo.Client, error)
• type Digits
  • func (d Digits) Length() int
• type OTPUtilities
  • func NewOtpUtilities(key []byte) OTPUtilities
• type RabbitMQ
  • func NewRabbitMQ(url string) (*RabbitMQ, error)
  • func (mq *RabbitMQ) BindQueue(queueName string, exchangeName string, routingKey string) error
  • func (mq *RabbitMQ) Close() error
  • func (mq *RabbitMQ) Consume(queueName string, consumerName string, autoAck bool) (<-chan amqp.Delivery, error)
  • func (mq *RabbitMQ) DeclareExchange(name string, kind string, durable bool) error
  • func (mq *RabbitMQ) DeclareQueue(name string, durable bool) (amqp.Queue, error)
  • func (mq *RabbitMQ) Publish(exchange string, routingKey string, mandatory bool, immediate bool, ...) error

Functions

func ConnectMongo

func ConnectMongo(uri string, maxRetries int, retryDelay time.Duration) (*mongo.Client, error)

Types

type Digits

type Digits int

const (
	OtpInterval        = 30 // Interval in seconds
	SixDigits   Digits = 6  // Number of digits in the OTP code
	EightDigits Digits = 8
)

func (Digits) Length

func (d Digits) Length() int

type OTPUtilities

type OTPUtilities interface {
	TOTPToken(counter int64, digits Digits) (int, error)
}

func NewOtpUtilities

func NewOtpUtilities(key []byte) OTPUtilities

type RabbitMQ

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

func NewRabbitMQ

func NewRabbitMQ(url string) (*RabbitMQ, error)

func (*RabbitMQ) BindQueue

func (mq *RabbitMQ) BindQueue(queueName string, exchangeName string, routingKey string) error

func (*RabbitMQ) Close

func (mq *RabbitMQ) Close() error

func (*RabbitMQ) Consume

func (mq *RabbitMQ) Consume(queueName string, consumerName string, autoAck bool) (<-chan amqp.Delivery, error)

func (*RabbitMQ) DeclareExchange

func (mq *RabbitMQ) DeclareExchange(name string, kind string, durable bool) error

func (*RabbitMQ) DeclareQueue

func (mq *RabbitMQ) DeclareQueue(name string, durable bool) (amqp.Queue, error)

func (*RabbitMQ) Publish

func (mq *RabbitMQ) Publish(exchange string, routingKey string, mandatory bool, immediate bool, msg amqp.Publishing) error