checkpoint

Documentation

Index

• type Checkpoint
  • func NewCheckpoint(partitionKey, rowKey string) *Checkpoint
• type Config
• type Table
  • func NewCheckpointTable(accountName, accountKey, checkpointsTableName string, timeout uint) (*Table, error)
  • func (ct *Table) CreateOrUpdateCheckpoint(checkpoint *Checkpoint) error
  • func (ct *Table) GetCheckpoint(partitionKey, rowKey string) (*Checkpoint, error)
  • func (ct *Table) UpdateCheckpoint(partitionKey, rowKey, etag string, index int64)

Types

type Checkpoint

type Checkpoint struct {
	PartitionKey string
	RowKey       string
	ETag         string
	Index        int64
	Length       int64
}

Checkpoint - represents a row in Azure Table

func NewCheckpoint

func NewCheckpoint(partitionKey, rowKey string) *Checkpoint

NewCheckpoint creates a new instance of Checkpoint

type Config

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

Config contains information required to connect to Azure Table

type Table

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

Table interacts with Azure Table to manage state checkpoints.

func NewCheckpointTable

func NewCheckpointTable(accountName, accountKey, checkpointsTableName string, timeout uint) (*Table, error)

NewCheckpointTable creates a new instance of CheckpointsTable. During initialization the table will be created if it doesn't already exist.

func (*Table) CreateOrUpdateCheckpoint

func (ct *Table) CreateOrUpdateCheckpoint(checkpoint *Checkpoint) error

CreateOrUpdateCheckpoint creates or updates checkpoint in checkpoints table

func (*Table) GetCheckpoint

func (ct *Table) GetCheckpoint(partitionKey, rowKey string) (*Checkpoint, error)

GetCheckpoint gets checkpoint from checkpoints table

func (*Table) UpdateCheckpoint

func (ct *Table) UpdateCheckpoint(partitionKey, rowKey, etag string, index int64)

UpdateCheckpoint updates etag and index on checkpoint identified by partition key and row key.