session

Documentation

Index

• func SetEvaluator(e evaluatorService)
• func SetIPCPublisher(p IPCPublisher)
• func SetLuaManager(fm *luaengine.FilterManager)
• func SetSnapshotCreator(sc SnapshotCreator)
• type IPCPublisher
• type Service
  • func NewService(q db.Querier) Service
• type Session
• type SnapshotCreator

Functions

func SetEvaluator

func SetEvaluator(e evaluatorService)

SetEvaluator sets the evaluator service used to trigger self-evaluation at session end.

func SetIPCPublisher

func SetIPCPublisher(p IPCPublisher)

SetIPCPublisher sets the ZMQ IPC publisher for cross-instance event broadcasting. Call this from app.go after the Bus is started (only for the primary instance).

func SetLuaManager

func SetLuaManager(fm *luaengine.FilterManager)

SetLuaManager sets the Lua filter manager used for session lifecycle hooks.

func SetSnapshotCreator

func SetSnapshotCreator(sc SnapshotCreator)

SetSnapshotCreator sets the snapshot creator used for session lifecycle snapshots.

Types

type IPCPublisher

type IPCPublisher interface {
	Publish(topic string, payload any) error
}

IPCPublisher is the minimal interface used by session to publish ZMQ events. A local interface is used to avoid import cycles between session and ipc packages.

type Service

type Service interface {
	pubsub.Suscriber[Session]
	Create(ctx context.Context, title string) (Session, error)
	CreateTitleSession(ctx context.Context, parentSessionID string) (Session, error)
	CreateTaskSession(ctx context.Context, toolCallID, parentSessionID, title string) (Session, error)
	GetACPSessionState(ctx context.Context, sessionID string) (string, error)
	Get(ctx context.Context, id string) (Session, error)
	List(ctx context.Context) ([]Session, error)
	SaveACPSessionState(ctx context.Context, sessionID string, state string) error
	Save(ctx context.Context, session Session) (Session, error)
	Delete(ctx context.Context, id string) error
	EndSession(ctx context.Context, id string) error
}

func NewService

func NewService(q db.Querier) Service

type Session

type Session struct {
	ID               string
	ParentSessionID  string
	Title            string
	MessageCount     int64
	PromptTokens     int64
	CompletionTokens int64
	SummaryMessageID string
	Cost             float64
	CreatedAt        int64
	UpdatedAt        int64
}

type SnapshotCreator

type SnapshotCreator interface {
	CreateSessionSnapshot(ctx context.Context, sessionID, snapshotType, description string) error
}

SnapshotCreator is an interface for creating snapshots without importing the snapshot package directly.