checkpoint

Documentation

Index

• func CreateTable(api *dynamodb.DynamoDB, env string, readCapacity, writeCapacity int64) error
• func MakeCreateTableInput(env string, readCapacity, writeCapacity int64) *dynamodb.CreateTableInput
• func TableName(env string) string
• type CP
  • func New(env string, api *dynamodb.DynamoDB) *CP
  • func (c *CP) Load(ctx context.Context, key string) (uint64, error)
  • func (c *CP) Save(ctx context.Context, key string, offset uint64) error

Functions

func CreateTable

func CreateTable(api *dynamodb.DynamoDB, env string, readCapacity, writeCapacity int64) error

CreateTable creates tables with specified capacity

func MakeCreateTableInput

func MakeCreateTableInput(env string, readCapacity, writeCapacity int64) *dynamodb.CreateTableInput

MakeCreateTableInput creates the create table description

func TableName

func TableName(env string) string

TableName provides name of checkpoints table for a given environment

Types

type CP

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

CP is a dynamodb backed implementation of publisher.Checkpointer

func New

func New(env string, api *dynamodb.DynamoDB) *CP

New constructs a new dynamodb backed CP that implements publisher.Checkpointer

func (*CP) Load

func (c *CP) Load(ctx context.Context, key string) (uint64, error)

Load the offset for the specified key from the data store

func (*CP) Save

func (c *CP) Save(ctx context.Context, key string, offset uint64) error

Save the offset for the specified key to the data store