Versions in this module Expand all Collapse all v0 v0.14.0 May 3, 2026 Changes in this version + type Manager struct + func New(options Options, params Params) (*Manager, error) + func (m *Manager) Allocate(authInfo *srpc.AuthInformation, request proto.AllocateRequest) (proto.AllocateResponse, error) + func (m *Manager) CancelAllocation(authInfo *srpc.AuthInformation, requestId proto.RequestId) error + func (m *Manager) GetUpdateQueue() queue.BroadcastQueue[proto.AllocationUpdateEntry] + func (m *Manager) UpdateTopology(t *topology.Topology) + func (m *Manager) WriteHtml(writer io.Writer) + type Options struct + CreateDeadline time.Duration + MaximumQueueSize uint64 + type Params struct + Logger log.DebugLogger + Storer Storer + UpdateChannelMaker UpdateChannelMaker + type Storer interface + DeleteUpdate func(position uint64) error + DeleteUserRequest func(username types.Username, reqId proto.RequestId) error + ReadUpdates func() (uint64, []proto.AllocationUpdateEntry, error) + ReadUserQueue func(username types.Username) (requestIDs []proto.RequestId, err error) + ReadUserRequest func(username types.Username, requestId proto.RequestId) (proto.AllocateRequest, error) + ReadUsersQueue func() (usernames []types.Username, err error) + WriteUpdate func(update proto.AllocationUpdateEntry, position uint64) error + WriteUserQueue func(username types.Username, requestIDs []proto.RequestId) error + WriteUserRequest func(username types.Username, reqId proto.RequestId, req proto.AllocateRequest) error + WriteUsersQueue func(usernames []types.Username) error + type UpdateChannelMaker interface + CloseUpdateChannel func(<-chan proto.Update) + MakeUpdateChannel func(proto.GetUpdatesRequest) <-chan proto.Update
Go to main page