allocator

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

type Options struct {
	CreateDeadline   time.Duration
	MaximumQueueSize uint64
}

type Params struct {
	Logger             log.DebugLogger
	Storer             Storer
	UpdateChannelMaker UpdateChannelMaker
}

type Storer interface {
	DeleteUpdate(position uint64) error
	DeleteUserRequest(username types.Username, reqId proto.RequestId) error
	ReadUpdates() (uint64, []proto.AllocationUpdateEntry, error)
	ReadUsersQueue() (usernames []types.Username, err error)
	ReadUserQueue(username types.Username) (
		requestIDs []proto.RequestId, err error)
	ReadUserRequest(username types.Username, requestId proto.RequestId) (
		proto.AllocateRequest, error)
	WriteUpdate(update proto.AllocationUpdateEntry, position uint64) error
	WriteUsersQueue(usernames []types.Username) error
	WriteUserQueue(username types.Username, requestIDs []proto.RequestId) error
	WriteUserRequest(username types.Username, reqId proto.RequestId,
		req proto.AllocateRequest) error
}

type UpdateChannelMaker interface {
	MakeUpdateChannel(proto.GetUpdatesRequest) <-chan proto.Update
	CloseUpdateChannel(<-chan proto.Update)
}