sessions

Documentation

Index

• type ErrGroupNotFound
  • func (g ErrGroupNotFound) Error() string
• type ErrRequestBinding
  • func (e ErrRequestBinding) Error() string
• type ErrTimeout
  • func (e ErrTimeout) Error() string
• type InstanceState
• type Manager
  • func NewSessionsManager(store tinykv.KV[instance.State], provider providers.Provider) Manager
• type SessionState
  • func (s *SessionState) IsReady() bool
  • func (s *SessionState) MarshalJSON() ([]byte, error)
  • func (s *SessionState) Status() string
• type SessionsManager
  • func (s *SessionsManager) ExpiresAfter(instance *instance.State, duration time.Duration)
  • func (sm *SessionsManager) LoadSessions(reader io.ReadCloser) error
  • func (s *SessionsManager) RequestReadySession(ctx context.Context, names []string, duration time.Duration, ...) (*SessionState, error)
  • func (s *SessionsManager) RequestReadySessionGroup(ctx context.Context, group string, duration time.Duration, ...) (sessionState *SessionState, err error)
  • func (s *SessionsManager) RequestSession(names []string, duration time.Duration) (sessionState *SessionState, err error)
  • func (s *SessionsManager) RequestSessionGroup(group string, duration time.Duration) (sessionState *SessionState, err error)
  • func (sm *SessionsManager) SaveSessions(writer io.WriteCloser) error
  • func (s *SessionsManager) Stop()

Types

type ErrGroupNotFound

type ErrGroupNotFound struct {
	Group           string
	AvailableGroups []string
}

func (ErrGroupNotFound) Error

func (g ErrGroupNotFound) Error() string

type ErrRequestBinding

type ErrRequestBinding struct {
	Err error
}

func (ErrRequestBinding) Error

func (e ErrRequestBinding) Error() string

type ErrTimeout

type ErrTimeout struct {
	Duration time.Duration
}

func (ErrTimeout) Error

func (e ErrTimeout) Error() string

type InstanceState

type InstanceState struct {
	Instance *instance.State `json:"instance"`
	Error    error           `json:"error"`
}

type Manager

type Manager interface {
	RequestSession(names []string, duration time.Duration) (*SessionState, error)
	RequestSessionGroup(group string, duration time.Duration) (*SessionState, error)
	RequestReadySession(ctx context.Context, names []string, duration time.Duration, timeout time.Duration) (*SessionState, error)
	RequestReadySessionGroup(ctx context.Context, group string, duration time.Duration, timeout time.Duration) (*SessionState, error)

	LoadSessions(io.ReadCloser) error
	SaveSessions(io.WriteCloser) error

	Stop()
}

func NewSessionsManager

func NewSessionsManager(store tinykv.KV[instance.State], provider providers.Provider) Manager

type SessionState

type SessionState struct {
	Instances *sync.Map
}

func (*SessionState) IsReady

func (s *SessionState) IsReady() bool

func (*SessionState) MarshalJSON

func (s *SessionState) MarshalJSON() ([]byte, error)

func (*SessionState) Status

func (s *SessionState) Status() string

type SessionsManager

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

func (*SessionsManager) ExpiresAfter

func (s *SessionsManager) ExpiresAfter(instance *instance.State, duration time.Duration)

func (*SessionsManager) LoadSessions

func (sm *SessionsManager) LoadSessions(reader io.ReadCloser) error

func (*SessionsManager) RequestReadySession

func (s *SessionsManager) RequestReadySession(ctx context.Context, names []string, duration time.Duration, timeout time.Duration) (*SessionState, error)

func (*SessionsManager) RequestReadySessionGroup

func (s *SessionsManager) RequestReadySessionGroup(ctx context.Context, group string, duration time.Duration, timeout time.Duration) (sessionState *SessionState, err error)

func (*SessionsManager) RequestSession

func (s *SessionsManager) RequestSession(names []string, duration time.Duration) (sessionState *SessionState, err error)

func (*SessionsManager) RequestSessionGroup

func (s *SessionsManager) RequestSessionGroup(group string, duration time.Duration) (sessionState *SessionState, err error)

func (*SessionsManager) SaveSessions

func (sm *SessionsManager) SaveSessions(writer io.WriteCloser) error

func (*SessionsManager) Stop

func (s *SessionsManager) Stop()