exp

Sep 2, 2026

retracted

Changes in this version

type FirestoreSessionStore

+ func (s *FirestoreSessionStore[State]) GetLatestSnapshotMetadata(ctx context.Context, sessionID string) (*aix.SessionSnapshot[State], error)

+ func (s *FirestoreSessionStore[State]) GetSnapshotMetadata(ctx context.Context, snapshotID string) (*aix.SessionSnapshot[State], error)

Jun 26, 2026

Changes in this version

+ const DefaultTTL

+ type CollectionOption interface

+ func WithCollection(collection string) CollectionOption

+ type FirestoreSessionStore struct

+ func NewFirestoreSessionStore[State any](ctx context.Context, g *genkit.Genkit, opts ...SessionStoreOption) (*FirestoreSessionStore[State], error)

+ func (s *FirestoreSessionStore[State]) GetLatestSnapshot(ctx context.Context, sessionID string) (*aix.SessionSnapshot[State], error)

+ func (s *FirestoreSessionStore[State]) GetSnapshot(ctx context.Context, snapshotID string) (*aix.SessionSnapshot[State], error)

+ func (s *FirestoreSessionStore[State]) OnSnapshotStatusChange(ctx context.Context, snapshotID string) <-chan aix.SnapshotStatus

+ func (s *FirestoreSessionStore[State]) SaveSnapshot(ctx context.Context, id string, ...) (*aix.SessionSnapshot[State], error)

+ type FirestoreStreamManager struct

+ func NewFirestoreStreamManager(ctx context.Context, g *genkit.Genkit, opts ...StreamManagerOption) (*FirestoreStreamManager, error)

+ func (m *FirestoreStreamManager) Open(ctx context.Context, streamID string) (streaming.StreamInput, error)

+ func (m *FirestoreStreamManager) Subscribe(ctx context.Context, streamID string) (<-chan streaming.StreamEvent, func(), error)

+ type SessionStoreOption interface

+ func WithCheckpointInterval(turns int) SessionStoreOption

+ func WithShardSize(bytes int) SessionStoreOption

+ func WithSnapshotPathPrefix(fn func(ctx context.Context) string) SessionStoreOption

+ type StreamManagerOption interface

+ func WithTTL(ttl time.Duration) StreamManagerOption

+ func WithTimeout(timeout time.Duration) StreamManagerOption