db

Documentation

Index

• type DDBClient
• type DynamoBucket
  • func (b DynamoBucket) Put(ctx context.Context, a types.AlarmEvent) error
  • func (b DynamoBucket) Remove(ctx context.Context, source string, name string) error

Types

type DDBClient

type DDBClient interface {
	PutItem(ctx context.Context, params *dynamodb.PutItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.PutItemOutput, error)
	DeleteItem(ctx context.Context, params *dynamodb.DeleteItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.DeleteItemOutput, error)
}

type DynamoBucket

type DynamoBucket struct {
	Client DDBClient
	Table  string
}

func (DynamoBucket) Put

func (b DynamoBucket) Put(ctx context.Context, a types.AlarmEvent) error

Put writes a record to DynamoDB

func (DynamoBucket) Remove

func (b DynamoBucket) Remove(ctx context.Context, source string, name string) error