session

package

Go to main page

Versions in this module

v0

v0.2.0

Sep 4, 2026

v0.1.24

Sep 4, 2026

Changes in this version

type SubagentEndData

+ JobID string

type SubagentStartData

+ Async bool

+ JobID string

v0.1.23

Sep 4, 2026

Changes in this version

+ func ResolveActiveSessionID(ctx context.Context, store agentkit.SessionStore, entryKey agentkit.SessionID) (agentkit.SessionID, error)

v0.1.22

Sep 3, 2026

v0.1.21

Sep 3, 2026

v0.1.20

Sep 3, 2026

v0.1.19

Sep 3, 2026

v0.1.18

Sep 2, 2026

Changes in this version

+ const TenantToolWorkDir

v0.1.17

Sep 1, 2026

v0.1.16

Sep 1, 2026

v0.1.15

Sep 1, 2026

v0.1.14

Sep 1, 2026

v0.1.13

Aug 31, 2026

v0.1.12

Aug 31, 2026

Changes in this version

+ const DefaultMaxStoredTextBytes

+ const MetadataLogicalChars

+ func EstimateLogicalChars(msg agentkit.ModelMessage) int

+ func HydrateLocalAttachments(ctx context.Context, msgs []agentkit.ModelMessage, ws workspace.Service, ...) ([]agentkit.ModelMessage, error)

+ func SanitizeModelMessageForStorage(msg agentkit.ModelMessage, maxTextBytes int) agentkit.ModelMessage

+ func SumLogicalCharsFromEvents(events []agentkit.SessionEvent, agentID agentkit.AgentID) int

v0.1.11

Aug 30, 2026

v0.1.10

Aug 30, 2026

Changes in this version

+ func ChannelKeyFromContext(ctx context.Context) string

+ func ChannelKeyMatches(jobChannelKey, contextChannelKey string) bool

v0.1.9

Aug 30, 2026

Changes in this version

+ func LatestSeq(ctx context.Context, s agentkit.Session) (agentkit.EventSeq, error)

+ func TrimCompacted(s agentkit.Session, agentID agentkit.AgentID, beforeSeq agentkit.EventSeq)

+ type IndexedMessage = compaction.IndexedMessage

+ func IndexMessagesForCompaction(ctx context.Context, events []agentkit.SessionEvent, ...) []IndexedMessage

type JSONL

+ func (s *JSONL) LatestSeq() agentkit.EventSeq

type JSONLConfig

+ MaxLoadedEvents int

type Memory

+ func (s *Memory) LatestSeq() agentkit.EventSeq

type StoreConfig

+ CacheIdleTTL string

+ MaxCachedSessions int

+ MaxLoadedEvents int

v0.1.8

Aug 29, 2026

v0.1.7

Aug 29, 2026

v0.1.6

Aug 29, 2026

Changes in this version

+ const LegacyUserMessageTemplate

+ func ActiveSessionEntryKey(platform string, delivery agentkit.SessionID, scope SessionScope, ...) agentkit.SessionID

+ func AgentStoreSessionID(ctx context.Context) agentkit.SessionID

+ func NewSessionID(base agentkit.SessionID) agentkit.SessionID

+ type ActiveSessionData struct

+ SessionID agentkit.SessionID

+ type AgentBindData struct

+ AgentID agentkit.AgentID

type JSONLConfig

+ UserMessageTemplate string

type MemoryConfig

+ UserMessageTemplate string

type StaticStore

+ func (s *StaticStore) ActiveSession(_ context.Context, id agentkit.SessionID) (agentkit.SessionID, error)

+ func (s *StaticStore) AgentBind(_ context.Context, id agentkit.SessionID) (agentkit.AgentID, error)

+ func (s *StaticStore) SetActiveSession(_ context.Context, id, active agentkit.SessionID) error

+ func (s *StaticStore) SetAgentBind(_ context.Context, id agentkit.SessionID, agent agentkit.AgentID) error

type Store

+ func (s *Store) ActiveSession(ctx context.Context, id agentkit.SessionID) (agentkit.SessionID, error)

+ func (s *Store) AgentBind(ctx context.Context, id agentkit.SessionID) (agentkit.AgentID, error)

+ func (s *Store) SetActiveSession(ctx context.Context, id, active agentkit.SessionID) error

+ func (s *Store) SetAgentBind(ctx context.Context, id agentkit.SessionID, agent agentkit.AgentID) error

type StoreConfig

+ UserMessageTemplate string

+ type UserMessageTemplateData struct

+ Metadata map[string]any

+ Text string

+ UserID string

v0.1.5

Aug 28, 2026

Changes in this version

+ type DeliveryParts struct

+ Channel string

+ Platform string

+ Routable bool

+ Thread string

+ User string

+ func ParseDelivery(id agentkit.SessionID, fallbackUser string) DeliveryParts

v0.1.4

Aug 28, 2026

v0.1.3

Aug 28, 2026

Changes in this version

+ const DefaultSessionScope

+ func ApplyScope(delivery agentkit.SessionID, scope SessionScope, userID string) agentkit.SessionID

+ func BuildDeliverySessionID(platform, channel, thread, user string) agentkit.SessionID

+ func DeliveryWithUser(delivery agentkit.SessionID, userID string) agentkit.SessionID

type SessionScope

+ func ParseScope(raw string) SessionScope

v0.1.2

Aug 27, 2026

v0.1.1

Aug 26, 2026

v0.1.0

Aug 26, 2026

Changes in this version

+ const CLICurrentLinkName

+ const DefaultCLISessionID

+ const FinishBlocked

+ const FinishCompleted

+ const InterruptedToolResultText

+ const TodoDone

+ const TodoInProgress

+ const TodoPending

+ func AppendAutoRetryEnd(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendAutoRetryStart(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendCompaction(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendMessage(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendOverflowRecovery(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendRunFinish(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendSessionRecovery(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendSkillLoad(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendStepEnd(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, step int) error

+ func AppendStepStart(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, step int) error

+ func AppendSubagentEnd(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendSubagentStart(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendSummarizationRetryEnd(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendSummarizationRetryStart(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendTodoUpdate(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendToolCall(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendToolResult(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendTurnContinue(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func AppendTurnEnd(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, steps int) error

+ func AppendTurnStart(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID) error

+ func AppendUsage(ctx context.Context, s agentkit.Session, agentID agentkit.AgentID, ...) error

+ func InterruptedToolResult(call agentkit.ToolCall) agentkit.ToolResult

+ func LastAssistantText(events []agentkit.SessionEvent, seq agentkit.EventSeq) string

+ func LatestEventSeq(events []agentkit.SessionEvent) agentkit.EventSeq

+ func NewCLISessionID() agentkit.SessionID

+ func NewJSONL(cfg JSONLConfig) (agentkit.Session, error)

+ func NewMemory(cfg MemoryConfig) (agentkit.Session, error)

+ func NewStatic(_ StaticConfig, deps StaticDeps) (agentkit.SessionStore, error)

+ func NewStore(cfg StoreConfig, deps StoreDeps) (agentkit.SessionStore, error)

+ func ReadAllEvents(ctx context.Context, s agentkit.Session) ([]agentkit.SessionEvent, error)

+ func RepeatedToolCalls(events []agentkit.SessionEvent, seq agentkit.EventSeq) int

+ func RunStartSeq(events []agentkit.SessionEvent) agentkit.EventSeq

+ func SlackSessionID(channelID, threadTS string) agentkit.SessionID

+ func SlackSessionIDForScope(scope SessionScope, channelID, threadTS, userID string) agentkit.SessionID

+ func StepCount(events []agentkit.SessionEvent, seq agentkit.EventSeq) int

+ type AutoRetryEndData struct

+ Attempt int

+ FinalError string

+ Success bool

+ type AutoRetryStartData struct

+ Attempt int

+ DelayMs int

+ ErrorMessage string

+ MaxAttempts int

+ type CLICurrentStore interface

+ ResolveCLICurrent func(ctx context.Context) (agentkit.SessionID, error)

+ SetCLICurrent func(ctx context.Context, id agentkit.SessionID) error

+ type FileBacked interface

+ FilePath func() string

+ type IncompleteTurn struct

+ AgentID agentkit.AgentID

+ OpenStep int

+ OrphanCalls []agentkit.ToolCall

+ StepsEnded int

+ StepsStarted int

+ TurnStartSeq agentkit.EventSeq

+ func ScanIncomplete(events []agentkit.SessionEvent) *IncompleteTurn

+ type JSONL struct

+ func (s *JSONL) Append(ctx context.Context, event agentkit.SessionEvent) (agentkit.EventSeq, error)

+ func (s *JSONL) DeriveMessages(ctx context.Context) ([]agentkit.ModelMessage, error)

+ func (s *JSONL) FilePath() string

+ func (s *JSONL) ID() agentkit.SessionID

+ func (s *JSONL) Read(ctx context.Context, from agentkit.EventSeq) ([]agentkit.SessionEvent, error)

+ type JSONLConfig struct

+ ID agentkit.SessionID

+ Path string

+ type Memory struct

+ func (s *Memory) Append(_ context.Context, event agentkit.SessionEvent) (agentkit.EventSeq, error)

+ func (s *Memory) DeriveMessages(_ context.Context) ([]agentkit.ModelMessage, error)

+ func (s *Memory) ID() agentkit.SessionID

+ func (s *Memory) Read(_ context.Context, from agentkit.EventSeq) ([]agentkit.SessionEvent, error)

+ type MemoryConfig struct

+ ID agentkit.SessionID

+ MaxToolResultBytes int

+ type OverflowRecoveryData struct

+ Applied int

+ Error string

+ Reason string

+ type RecoveryData struct

+ ClosedStep int

+ OrphanResults int

+ Reason string

+ Steps int

+ TurnStartSeq agentkit.EventSeq

+ func RepairIncomplete(ctx context.Context, s agentkit.Session, turn *IncompleteTurn) (RecoveryData, error)

+ type RunFinishData struct

+ Status string

+ Summary string

+ func FinishAfter(events []agentkit.SessionEvent, seq agentkit.EventSeq) *RunFinishData

+ type SessionScope string

+ const ScopeChannel

+ const ScopeThread

+ const ScopeUser

+ type StaticConfig struct

+ type StaticDeps struct

+ Session agentkit.Session

+ type StaticStore struct

+ func NewStaticStore(sess agentkit.Session) *StaticStore

+ func (s *StaticStore) Get(_ context.Context, id agentkit.SessionID) (agentkit.Session, error)

+ type StepEndData struct

+ Step int

+ type StepStartData struct

+ Step int

+ type Store struct

+ func (s *Store) Commands() []agentkit.Command

+ func (s *Store) Get(ctx context.Context, id agentkit.SessionID) (agentkit.Session, error)

+ func (s *Store) ResolveCLICurrent(ctx context.Context) (agentkit.SessionID, error)

+ func (s *Store) SetCLICurrent(ctx context.Context, id agentkit.SessionID) error

+ type StoreConfig struct

+ Dir string

+ type StoreDeps struct

+ Workspace workspace.Service

+ type SubagentEndData struct

+ Agent string

+ Error string

+ Session string

+ Status string

+ Steps int

+ Summary string

+ type SubagentStartData struct

+ Agent string

+ Session string

+ Task string

+ type SummarizationRetryEndData struct

+ Attempt int

+ FinalError string

+ Success bool

+ type SummarizationRetryStartData struct

+ Attempt int

+ DelayMs int

+ ErrorMessage string

+ MaxAttempts int

+ type Todo struct

+ ID string

+ Status string

+ Title string

+ func LatestTodos(events []agentkit.SessionEvent) []Todo

+ func PendingTodos(items []Todo) []Todo

+ func (t Todo) Done() bool

+ type TodoUpdateData struct

+ Items []Todo

+ type TurnContinueData struct

+ Messages []agentkit.ModelMessage

+ Reason string

+ Segment int

+ Steps int

+ type TurnEndData struct

+ Steps int

+ type TurnStartData struct

+ type UsageData struct

+ InputTokens int

+ OutputTokens int

+ TotalTokens int

+ func LatestUsage(events []agentkit.SessionEvent) UsageData

+ func TotalUsage(events []agentkit.SessionEvent, seq agentkit.EventSeq) UsageData

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL