shard_watcher

Documentation

Index

• type RunInput
• type Watcher
  • func New(input *RunInput) *Watcher
  • func (w *Watcher) ActiveWorkerCount() int32
  • func (w *Watcher) DispatchedCount() int32
  • func (w *Watcher) RunWorkers() error
  • func (w *Watcher) Started() bool

Types

type RunInput

type RunInput struct {
	Context           context.Context
	ContextCancelFunc context.CancelFunc

	InputTableName       string
	OperationDescription string

	Client *dynamodbstreams.DynamoDBStreams
}

type Watcher

type Watcher struct {
	*RunInput

	ShardProcessor func(*shard_tree.Shard) error
	StreamARN      string
	// contains filtered or unexported fields
}

func New

func New(input *RunInput) *Watcher

New creates a new watcher

func (*Watcher) ActiveWorkerCount

func (w *Watcher) ActiveWorkerCount() int32

func (*Watcher) DispatchedCount

func (w *Watcher) DispatchedCount() int32

func (*Watcher) RunWorkers

func (w *Watcher) RunWorkers() error

func (*Watcher) Started

func (w *Watcher) Started() bool