redis

Documentation

Index

• type Checkpoint
  • func New(appName string) (*Checkpoint, error)
  • func (c *Checkpoint) Get(streamName, shardID string) (string, error)
  • func (c *Checkpoint) Set(streamName, shardID, sequenceNumber string) error

Types

type Checkpoint

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

Checkpoint stores and retreives the last evaluated key from a DDB scan

func New

func New(appName string) (*Checkpoint, error)

New returns a checkpoint that uses Redis for underlying storage

func (*Checkpoint) Get

func (c *Checkpoint) Get(streamName, shardID string) (string, error)

Get fetches the checkpoint for a particular Shard.

func (*Checkpoint) Set

func (c *Checkpoint) Set(streamName, shardID, sequenceNumber string) error

Set stores a checkpoint for a shard (e.g. sequence number of last record processed by application). Upon failover, record processing is resumed from this point.