checkpoint

Documentation

Index

• type CheckpointManager
  • func GetDefaultCheckpointManager(config config.Config) (CheckpointManager, error)
• type DynamoCheckpointManager
  • func (cm *DynamoCheckpointManager) GetCheckpoint(Id string) (string, time.Time, error)
  • func (cm *DynamoCheckpointManager) SetCheckpoint(Id string, sequenceNumber string) error
• type InMemoryCheckpointManager
  • func (cm *InMemoryCheckpointManager) GetCheckpoint(Id string) (string, time.Time, error)
  • func (cm *InMemoryCheckpointManager) SetCheckpoint(Id string, sequenceNumber string) error
• type StorageConfig
  • func GetStorageConfig(config config.Config) StorageConfig

Types

type CheckpointManager

type CheckpointManager interface {
	GetCheckpoint(Id string) (string, time.Time, error)
	SetCheckpoint(Id string, sequenceNumber string) error
}

func GetDefaultCheckpointManager

func GetDefaultCheckpointManager(config config.Config) (CheckpointManager, error)

type DynamoCheckpointManager

type DynamoCheckpointManager struct {
	sync.Mutex
	StorageConfig
	// contains filtered or unexported fields
}

func (*DynamoCheckpointManager) GetCheckpoint

func (cm *DynamoCheckpointManager) GetCheckpoint(Id string) (string, time.Time, error)

func (*DynamoCheckpointManager) SetCheckpoint

func (cm *DynamoCheckpointManager) SetCheckpoint(Id string, sequenceNumber string) error

type InMemoryCheckpointManager

type InMemoryCheckpointManager struct {
	sync.Mutex
	StorageConfig
	// contains filtered or unexported fields
}

func (*InMemoryCheckpointManager) GetCheckpoint

func (cm *InMemoryCheckpointManager) GetCheckpoint(Id string) (string, time.Time, error)

func (*InMemoryCheckpointManager) SetCheckpoint

func (cm *InMemoryCheckpointManager) SetCheckpoint(Id string, sequenceNumber string) error

type StorageConfig

type StorageConfig struct {
	Env                    string
	StorageType            string
	Table                  string
	Region                 string
	UpdateFrequencySeconds int
}

func GetStorageConfig

func GetStorageConfig(config config.Config) StorageConfig