sessions

Documentation

Index

• 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)
  • func (s *SessionsManager) RequestSessionGroup(group string, duration time.Duration) (sessionState *SessionState)
  • func (sm *SessionsManager) SaveSessions(writer io.WriteCloser) error
  • func (s *SessionsManager) Stop()

Types

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
	RequestSessionGroup(group string, duration time.Duration) *SessionState
	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)

func (*SessionsManager) RequestSessionGroup

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

func (*SessionsManager) SaveSessions

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

func (*SessionsManager) Stop

func (s *SessionsManager) Stop()