shard_tree

package
v0.0.0-...-2bcf1be Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 23, 2020 License: AGPL-3.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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")
)

Functions

This section is empty.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.