infra

Documentation

Index

• type Config
  • func GetConfig() Config
• type QueueNotifier
  • func NewQueueNotifier(cfg *Config, q string) *QueueNotifier
  • func (n *QueueNotifier) Send(msg interface{}) error
• type Recorder
  • func NewRecorder(cfg *Config, table string) *Recorder
  • func (r *Recorder) Record(rec interface{}) error
• type TopicNotifier
  • func NewTopicNotifier(cfg *Config, t string) *TopicNotifier
  • func (n *TopicNotifier) Send(msg interface{}) error

Types

type Config

type Config struct {
	Session *session.Session
}

A Config provides a collection of configuration values the AWS SDK will use to setup its components.

func GetConfig

func GetConfig() Config

GetConfig collects the configuration from the environment variables

type QueueNotifier

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

QueueNotifier basic attributes for sending notifications to a topic

func NewQueueNotifier

func NewQueueNotifier(cfg *Config, q string) *QueueNotifier

NewQueueNotifier creates a basic configuration for publishing to a SNS topic

func (*QueueNotifier) Send

func (n *QueueNotifier) Send(msg interface{}) error

Send send a notification to a topic

type Recorder

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

Recorder provides the an abstraction to record data to DynamoDB.

func NewRecorder

func NewRecorder(cfg *Config, table string) *Recorder

func (*Recorder) Record

func (r *Recorder) Record(rec interface{}) error

type TopicNotifier

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

TopicNotifier basic attributes for sending notifications to a topic

func NewTopicNotifier

func NewTopicNotifier(cfg *Config, t string) *TopicNotifier

NewTopicNotifier creates a basic configuration for publishing to a SNS topic

func (*TopicNotifier) Send

func (n *TopicNotifier) Send(msg interface{}) error

Send send a notification to a topic