kinesumeriface

Documentation

Index

• Constants
• type Checkpointer
• type Error
• type Kinesis
• type Kinesumer
• type Provisioner
• type Record

Constants

const (
	ECrit  = "crit"
	EError = "error"
	EWarn  = "warn"
	EInfo  = "info"
	EDebug = "debug"
)

Types

type Checkpointer

type Checkpointer interface {
	DoneC() chan<- Record
	Begin() error
	End()
	GetStartSequence(shardID string) string
	Sync()
}

type Error

type Error interface {
	Severity() string
	Origin() error
	Error() string
}

type Kinesis

type Kinesis kinesisiface.KinesisAPI

type Kinesumer

type Kinesumer interface {
	Begin() (int, error)
	End()
	Records() <-chan Record
}

type Provisioner

type Provisioner interface {
	TryAcquire(shardID string) error
	Release(shardID string) error
	Heartbeat(shardID string) error
	TTL() time.Duration
}

type Record

type Record interface {
	Data() []byte
	PartitionKey() string
	SequenceNumber() string
	ShardId() string
	MillisBehindLatest() int64
	Done()
}