backlog

Documentation

Index

• Variables
• type AckFunc
• type Backlog

Variables

var (
	// ErrNoMoreObjects is returned on Pop() when there are no more objects
	// to return
	ErrNoMoreObjects = errors.New("no more objects")
	// ErrAlreadyExists is returned on Push() when combination of object/key
	// already exists
	ErrAlreadyExists = errors.New("already exists")
)

Types

type AckFunc

type AckFunc func()

AckFunc allows the handler of a popped object to acknowledge it has been handled and thus can be removed from the backlog.

type Backlog

type Backlog interface {
	Push(object.Object, ...*crypto.PublicKey) error
	Pop(*crypto.PublicKey) (object.Object, AckFunc, error)
}

Backlog keeps track of objects than need to be sent to each recipient.