temp

Documentation

Overview

Package temp implements temporary storage interfaces that will be valid only during runtime and will evaporate after shutdown of program.

Index

• Variables
• type OnlineUsers
  • func NewOnlineUsers() *OnlineUsers
  • func (o *OnlineUsers) All(ctx context.Context) ([]string, error)
  • func (o *OnlineUsers) IsOnline(ctx context.Context, id string) (bool, error)
  • func (o *OnlineUsers) Update(ctx context.Context, ids []string) error
• type StatusTx
  • func NewStatusTx() *StatusTx
  • func (s *StatusTx) DevicesStatus(ctx context.Context, f func(context.Context, storage.Status) error) error

Variables

var ErrContextDone = errors.New("temp: context is done, performed graceful shutdown")

Types

type OnlineUsers

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

func NewOnlineUsers

func NewOnlineUsers() *OnlineUsers

func (*OnlineUsers) All

func (o *OnlineUsers) All(ctx context.Context) ([]string, error)

func (*OnlineUsers) IsOnline

func (o *OnlineUsers) IsOnline(ctx context.Context, id string) (bool, error)

func (*OnlineUsers) Update

func (o *OnlineUsers) Update(ctx context.Context, ids []string) error

type StatusTx

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

StatusTx implements storage.StatusTx interface for temporary in memory storage.

func NewStatusTx

func NewStatusTx() *StatusTx

NewStatusTx is the only one safe constructor for StatusTx.

func (*StatusTx) DevicesStatus

func (s *StatusTx) DevicesStatus(ctx context.Context, f func(context.Context, storage.Status) error) error

DevicesStatus accepts function that manipulates number of unknown devices and online users in single safe transaction.