inmemory

Documentation

Index

• type Store
  • func New() *Store
  • func (s *Store) AppendEvent(ctx context.Context, req *session.Session, ev *session.Event) error
  • func (s *Store) GetOrCreate(ctx context.Context, req *session.Session) (*session.Session, error)
  • func (s *Store) ListContextWindowEvents(ctx context.Context, req *session.Session) ([]*session.Event, error)
  • func (s *Store) ListEvents(ctx context.Context, req *session.Session) ([]*session.Event, error)
  • func (s *Store) ListEventsAfter(ctx context.Context, req *session.Session, afterCursor string, limit int) ([]*session.Event, string, error)
  • func (s *Store) ReplaceState(ctx context.Context, req *session.Session, values map[string]any) error
  • func (s *Store) SessionExists(ctx context.Context, req *session.Session) (bool, error)
  • func (s *Store) SnapshotState(ctx context.Context, req *session.Session) (map[string]any, error)
  • func (s *Store) UpdateState(ctx context.Context, req *session.Session, ...) error

Types

type Store

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

Store is a thread-safe in-memory session store.

func New

func New() *Store

func (*Store) AppendEvent

func (s *Store) AppendEvent(ctx context.Context, req *session.Session, ev *session.Event) error

func (*Store) GetOrCreate

func (s *Store) GetOrCreate(ctx context.Context, req *session.Session) (*session.Session, error)

func (*Store) ListContextWindowEvents

func (s *Store) ListContextWindowEvents(ctx context.Context, req *session.Session) ([]*session.Event, error)

func (*Store) ListEvents

func (s *Store) ListEvents(ctx context.Context, req *session.Session) ([]*session.Event, error)

func (*Store) ListEventsAfter

func (s *Store) ListEventsAfter(ctx context.Context, req *session.Session, afterCursor string, limit int) ([]*session.Event, string, error)

func (*Store) ReplaceState

func (s *Store) ReplaceState(ctx context.Context, req *session.Session, values map[string]any) error

func (*Store) SessionExists

func (s *Store) SessionExists(ctx context.Context, req *session.Session) (bool, error)

func (*Store) SnapshotState

func (s *Store) SnapshotState(ctx context.Context, req *session.Session) (map[string]any, error)

func (*Store) UpdateState

func (s *Store) UpdateState(ctx context.Context, req *session.Session, update func(map[string]any) (map[string]any, error)) error