consumer

type CommitReader interface {
	GetCommit(ctx context.Context, cid cid.Cid) (commit, error)
}

type Consumer interface {
	Consume(globalCtx context.Context, handler MessageHandler) error
}

type FakeCommitReader struct {
	Commits map[cid.Cid]commit
}

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

type FirstToLastConsumerConfig struct {
	PollInterval time.Duration
	PollTimeout  time.Duration
}

type MessageFandlerFunc func(ctx context.Context, message storage.ProtoUnmarshallable) error

type MessageHandler interface {
	Handle(ctx context.Context, message storage.ProtoUnmarshallable) error
}

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