shard_tree

Documentation

Index

• Variables
• type Shard
  • func ShardsForDynamoDBShards(dynamodbShards []*dynamodbstreams.Shard) []*Shard
• type ShardStatus
• type ShardTree
  • func New() *ShardTree
  • func (t *ShardTree) Add(shards []*Shard) error
  • func (t *ShardTree) AvailableShards() []*Shard
  • func (t *ShardTree) Count() int
  • func (t *ShardTree) ShardComplete(shard *Shard) error

Variables

var (
	ErrShardNotFound = errors.New("Shard not found in tree")
	ErrShardConflict = errors.New("Conflicting shard already exists in tree")

	ErrAncestorInProgress = errors.New("Ancestor in-progress")
	ErrAncestorIncomplete = errors.New("Ancestor incomplete")
)

Types

type Shard

type Shard struct {
	Id       string
	ParentId string

	Parent *Shard
}

func ShardsForDynamoDBShards

func ShardsForDynamoDBShards(dynamodbShards []*dynamodbstreams.Shard) []*Shard

type ShardStatus

type ShardStatus struct {
	Shard *Shard

	InProgress bool
	Complete   bool
}

type ShardTree

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

func New

func New() *ShardTree

func (*ShardTree) Add

func (t *ShardTree) Add(shards []*Shard) error

func (*ShardTree) AvailableShards

func (t *ShardTree) AvailableShards() []*Shard

func (*ShardTree) Count

func (t *ShardTree) Count() int

func (*ShardTree) ShardComplete

func (t *ShardTree) ShardComplete(shard *Shard) error