redis

Documentation

Index

• type Checkpoint
  • func NewCheckpoint(redis *redis.Client) Checkpoint
  • func (c Checkpoint) Get(key string) (string, error)
  • func (c Checkpoint) Set(key, value string) error

Types

type Checkpoint

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

Checkpoint implements a KV store to keep track of processing checkpoints.

func NewCheckpoint

func NewCheckpoint(redis *redis.Client) Checkpoint

NewCheckpoint creates a new checkpoint storage.

func (Checkpoint) Get

func (c Checkpoint) Get(key string) (string, error)

Get the key/value.

func (Checkpoint) Set

func (c Checkpoint) Set(key, value string) error

Set the key/value.