fsstorer

package

v0.14.0 Latest Latest Go to latest Published: May 3, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(topDir string, logger log.DebugLogger) (*Storer, error)

func (s *Storer) DeleteUpdate(position uint64) error

func (s *Storer) DeleteUserRequest(username types.Username,
	requestId proto.RequestId) error

func (s *Storer) ReadUpdates() (uint64, []proto.AllocationUpdateEntry, error)

func (s *Storer) ReadUserQueue(username types.Username) (
	[]proto.RequestId, error)

func (s *Storer) ReadUserRequest(username types.Username,
	requestId proto.RequestId) (proto.AllocateRequest, error)

func (s *Storer) ReadUsersQueue() ([]types.Username, error)

func (s *Storer) WriteUpdate(update proto.AllocationUpdateEntry,
	position uint64) error

func (s *Storer) WriteUserQueue(username types.Username,
	requestIDs []proto.RequestId) error

func (s *Storer) WriteUserRequest(username types.Username,
	requestId proto.RequestId, request proto.AllocateRequest) error

func (s *Storer) WriteUsersQueue(usernames []types.Username) error