redis

package
v0.3.2-0...-bc2e1b9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 21, 2019 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL