sessionstore

Documentation

Overview

Package sessionstore persists native Google ADK sessions as JSONL files.

Package sessionstore provides a durable native Google ADK session service.

Index

• Variables
• type Options
• type Store
  • func Open(dir string) (*Store, error)
  • func OpenWith(o Options) (*Store, error)
  • func (s *Store) AppendEvent(ctx context.Context, current session.Session, event *session.Event) error
  • func (s *Store) AppendSidecar(ctx context.Context, app, user, id, kind string, value any) error
  • func (s *Store) Close() error
  • func (s *Store) Create(ctx context.Context, req *session.CreateRequest) (*session.CreateResponse, error)
  • func (s *Store) Delete(ctx context.Context, req *session.DeleteRequest) error
  • func (s *Store) Get(ctx context.Context, req *session.GetRequest) (*session.GetResponse, error)
  • func (s *Store) List(ctx context.Context, req *session.ListRequest) (*session.ListResponse, error)
  • func (s *Store) LoadSidecar(ctx context.Context, app, user, id, kind string, destination any) (bool, error)

Variables

var (
	// ErrSessionNotFound reports an absent session log.
	ErrSessionNotFound = errors.New("sessionstore: session not found")
	// ErrSessionExists reports an attempt to create an existing session.
	ErrSessionExists = errors.New("sessionstore: session exists")
	// ErrCorruptLog reports a complete invalid JSONL record.
	ErrCorruptLog = errors.New("sessionstore: corrupt log")
	// ErrInvalidID reports an invalid app, user, or session identifier.
	ErrInvalidID = errors.New("sessionstore: invalid identifier")
	// ErrInvalidEvent reports an event that cannot be persisted.
	ErrInvalidEvent = errors.New("sessionstore: invalid event")
	// ErrClosed reports an operation on a closed store.
	ErrClosed = errors.New("sessionstore: closed")
)

Types

type Options

type Options struct {
	Dir         string
	Fsync       *bool
	NewID       func() string
	Logger      *slog.Logger
	WarningSink warning.Warner
}

type Store

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

func Open

func Open(dir string) (*Store, error)

func OpenWith

func OpenWith(o Options) (*Store, error)

func (*Store) AppendEvent

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

func (*Store) AppendSidecar

func (s *Store) AppendSidecar(ctx context.Context, app, user, id, kind string, value any) error

func (*Store) Close

func (s *Store) Close() error

func (*Store) Create

func (s *Store) Create(ctx context.Context, req *session.CreateRequest) (*session.CreateResponse, error)

func (*Store) Delete

func (s *Store) Delete(ctx context.Context, req *session.DeleteRequest) error

func (*Store) Get

func (s *Store) Get(ctx context.Context, req *session.GetRequest) (*session.GetResponse, error)

func (*Store) List

func (s *Store) List(ctx context.Context, req *session.ListRequest) (*session.ListResponse, error)

func (*Store) LoadSidecar

func (s *Store) LoadSidecar(ctx context.Context, app, user, id, kind string, destination any) (bool, error)