session

Documentation

Index

• Constants
• func Delete(ctx context.Context, id string) error
• func InitService(dbConn *sql.DB) error
• func Subscribe(ctx context.Context) <-chan pubsub.Event[Session]
• type Service
  • func GetService() Service
• type Session
  • func Create(ctx context.Context, title string) (Session, error)
  • func CreateTaskSession(ctx context.Context, toolCallID, parentSessionID, title string) (Session, error)
  • func Get(ctx context.Context, id string) (Session, error)
  • func List(ctx context.Context) ([]Session, error)
  • func Update(ctx context.Context, session Session) (Session, error)

Constants

const (
	EventSessionCreated pubsub.EventType = "session_created"
	EventSessionUpdated pubsub.EventType = "session_updated"
	EventSessionDeleted pubsub.EventType = "session_deleted"
)

Functions

func Delete

func Delete(ctx context.Context, id string) error

func InitService

func InitService(dbConn *sql.DB) error

func Subscribe

func Subscribe(ctx context.Context) <-chan pubsub.Event[Session]

Types

type Service

type Service interface {
	pubsub.Subscriber[Session]

	Create(ctx context.Context, title string) (Session, error)
	CreateTaskSession(ctx context.Context, toolCallID, parentSessionID, title string) (Session, error)
	Get(ctx context.Context, id string) (Session, error)
	List(ctx context.Context) ([]Session, error)
	Update(ctx context.Context, session Session) (Session, error)
	Delete(ctx context.Context, id string) error
}

func GetService

func GetService() Service

type Session

type Session struct {
	ID               string
	ParentSessionID  string
	Title            string
	MessageCount     int64
	PromptTokens     int64
	CompletionTokens int64
	Cost             float64
	Summary          string
	SummarizedAt     time.Time
	CreatedAt        time.Time
	UpdatedAt        time.Time
}

func Create

func Create(ctx context.Context, title string) (Session, error)

func CreateTaskSession

func CreateTaskSession(ctx context.Context, toolCallID, parentSessionID, title string) (Session, error)

func Get

func Get(ctx context.Context, id string) (Session, error)

func List

func List(ctx context.Context) ([]Session, error)

func Update

func Update(ctx context.Context, session Session) (Session, error)