maintenance

Documentation

Index

• type EventStore
• type Iter
• type Task
• type TaskHandler

Types

type EventStore

type EventStore interface {
	Insert(ctx context.Context, task Task) error
	Query(ctx context.Context, limit int, taskHandler TaskHandler) error
	Remove(ctx context.Context, task Task) error
}

EventStore provides interface over the maintenance functionality for an event store

type Iter

type Iter interface {
	Next(ctx context.Context, task *Task) bool
	Err() error
}

Iter provides iterator over maintenance db records

type Task

type Task struct {
	GroupID     string
	AggregateID string
	Version     uint64
}

Task used to target a specific db record

type TaskHandler

type TaskHandler interface {
	Handle(ctx context.Context, iter Iter) (err error)
}

TaskHandler handles the maintenance db queries