store

Documentation

Overview

The memory store provides a store that can be used for testing and single-threaded applications. DO NOT USE this in a production application where persistence beyond a single application lifecycle is necessary or when there are multiple consumers.

Index

• type Store
  • func New() *Store
  • func (c *Store) GetCheckpoint(streamName, shardID string) (string, error)
  • func (c *Store) SetCheckpoint(streamName, shardID, sequenceNumber string) error

Types

type Store

type Store struct {
	sync.Map
}

func New

func New() *Store

func (*Store) GetCheckpoint

func (c *Store) GetCheckpoint(streamName, shardID string) (string, error)

func (*Store) SetCheckpoint

func (c *Store) SetCheckpoint(streamName, shardID, sequenceNumber string) error