Versions in this module Expand all Collapse all v0 v0.79.3 Jan 16, 2026 v0.79.2 Jan 15, 2026 v0.79.1 Jan 14, 2026 v0.79.0 Jan 9, 2026 Changes in this version + const ListBucketObjectsName + const ListBucketsName + const ListTablesName + const ProjectStatusName + const QuerySQLName + const ShowTableName type BaseSession + func (s *BaseSession) Forked() bool + func (s *BaseSession) Shared() bool + func (s *BaseSession) UpdateSharedUntilMessageID(ctx context.Context, messageID string) error + type ColumnInfo struct + Name string + Type string + type ListBucketObjects struct + Runtime *runtime.Runtime + func (t *ListBucketObjects) CheckAccess(ctx context.Context) (bool, error) + func (t *ListBucketObjects) Handler(ctx context.Context, args *ListBucketObjectsArgs) (*ListBucketObjectsResult, error) + func (t *ListBucketObjects) Spec() *mcp.Tool + type ListBucketObjectsArgs struct + Bucket string + Connector string + PageSize int + PageToken string + Path string + type ListBucketObjectsResult struct + NextPageToken string + Objects []ObjectInfo + type ListBuckets struct + Runtime *runtime.Runtime + func (t *ListBuckets) CheckAccess(ctx context.Context) (bool, error) + func (t *ListBuckets) Handler(ctx context.Context, args *ListBucketsArgs) (*ListBucketsResult, error) + func (t *ListBuckets) Spec() *mcp.Tool + type ListBucketsArgs struct + Connector string + type ListBucketsResult struct + Buckets []string + type ListTables struct + Runtime *runtime.Runtime + func (t *ListTables) CheckAccess(ctx context.Context) (bool, error) + func (t *ListTables) Handler(ctx context.Context, args *ListTablesArgs) (*ListTablesResult, error) + func (t *ListTables) Spec() *mcp.Tool + type ListTablesArgs struct + Connector string + PageSize int + PageToken string + SearchPattern string + type ListTablesResult struct + NextPageToken string + Tables []TableInfo + type ObjectInfo struct + IsDir bool + ModifiedOn *time.Time + Path string + Size int64 + type ProjectStatus struct + Runtime *runtime.Runtime + func (t *ProjectStatus) CheckAccess(ctx context.Context) (bool, error) + func (t *ProjectStatus) Handler(ctx context.Context, args *ProjectStatusArgs) (*ProjectStatusResult, error) + func (t *ProjectStatus) Spec() *mcp.Tool + type ProjectStatusArgs struct + Kind string + Name string + Path string + WhereError bool + type ProjectStatusResult struct + DefaultOLAPConnector string + ParseErrors []map[string]any + Resources []map[string]any + VariablesNames []string + type QuerySQL struct + Runtime *runtime.Runtime + func (t *QuerySQL) CheckAccess(ctx context.Context) (bool, error) + func (t *QuerySQL) Handler(ctx context.Context, args *QuerySQLArgs) (*QuerySQLResult, error) + func (t *QuerySQL) Spec() *mcp.Tool + type QuerySQLArgs struct + Connector string + SQL string + TimeoutSeconds int + type QuerySQLResult struct + Data []map[string]any type Runner + func (r *Runner) ForkSession(ctx context.Context, opts *SessionOptions) (string, error) + type ShowTable struct + Runtime *runtime.Runtime + func (t *ShowTable) CheckAccess(ctx context.Context) (bool, error) + func (t *ShowTable) Handler(ctx context.Context, args *ShowTableArgs) (*ShowTableResult, error) + func (t *ShowTable) Spec() *mcp.Tool + type ShowTableArgs struct + Connector string + Database string + DatabaseSchema string + Table string + type ShowTableResult struct + Columns []ColumnInfo + IsView bool + Name string + PhysicalSizeBytes int64 + type TableInfo struct + Database string + DatabaseSchema string + IsDefaultDatabaseSchema bool + IsView bool + Name string v0.78.2 Jan 9, 2026 v0.78.1 Jan 7, 2026 v0.78.0 Dec 22, 2025 Changes in this version + const AnalystAgentName + const CreateChartName + const DevelopMetricsViewName + const DevelopModelName + const DeveloperAgentName + const GetMetricsViewName + const ListFilesName + const ListMetricsViewsName + const QueryMetricsViewName + const QueryMetricsViewSummaryName + const ReadFileName + const RouterAgentName + const SearchFilesName + const WriteFileName + func NewInternalError(err error) error + func NewTextCompletionMessage(role Role, content string) *aiv1.CompletionMessage + func RegisterTool[In, Out any](s *Runner, t Tool[In, Out]) + func WithSession(ctx context.Context, s *Session) context.Context + type AddMessageOptions struct + Content string + ContentType MessageContentType + Role Role + Tool string + Type MessageType + type AnalystAgent struct + Runtime *runtime.Runtime + func (t *AnalystAgent) CheckAccess(ctx context.Context) (bool, error) + func (t *AnalystAgent) Handler(ctx context.Context, args *AnalystAgentArgs) (*AnalystAgentResult, error) + func (t *AnalystAgent) Spec() *mcp.Tool + type AnalystAgentArgs struct + Dimensions []string + Explore string + Measures []string + Prompt string + TimeEnd time.Time + TimeStart time.Time + Where *metricsview.Expression + func (a *AnalystAgentArgs) ToLLM() *aiv1.ContentBlock + type AnalystAgentResult struct + Response string + func (r *AnalystAgentResult) ToLLM() *aiv1.ContentBlock + type BaseSession struct + func (s *BaseSession) CatalogSession() *drivers.AISession + func (s *BaseSession) Claims() *runtime.SecurityClaims + func (s *BaseSession) ExpandMessages(msgs []*Message, fn func(m *Message) []*Message) []*Message + func (s *BaseSession) Flush(ctx context.Context) error + func (s *BaseSession) ID() string + func (s *BaseSession) InstanceID() string + func (s *BaseSession) LatestMessage(predicates ...Predicate) (*Message, bool) + func (s *BaseSession) LatestRootCall() *Message + func (s *BaseSession) Message(predicates ...Predicate) (*Message, bool) + func (s *BaseSession) Messages(predicates ...Predicate) []*Message + func (s *BaseSession) MessagesWithChildren(predicates ...Predicate) []*Message + func (s *BaseSession) MessagesWithDescendents(predicates ...Predicate) []*Message + func (s *BaseSession) MessagesWithResults(predicates ...Predicate) []*Message + func (s *BaseSession) NextIndex() int + func (s *BaseSession) ProjectInstructions() string + func (s *BaseSession) SetLLM(acquireLLM func(ctx context.Context) (drivers.AIService, func(), error)) + func (s *BaseSession) Subscribe() chan *Message + func (s *BaseSession) Title() string + func (s *BaseSession) Unsubscribe(ch chan *Message) + func (s *BaseSession) UpdateTitle(ctx context.Context, title string) error + func (s *BaseSession) UpdateUserAgent(ctx context.Context, userAgent string) error + func (s *BaseSession) WithParent(messageID string) *Session + type CallOptions struct + Args any + Handler func(context.Context) (any, error) + Name string + Out any + Role Role + Unwrap bool + type CallResult struct + Call *Message + Result *Message + type CallToolOptions struct + Args any + Out any + Role Role + Tool string + Unwrap bool + type CompiledTool struct + CheckAccess func(context.Context) (bool, error) + JSONHandler func(ctx context.Context, input json.RawMessage) (json.RawMessage, error) + Name string + RegisterWithMCPServer func(srv *mcp.Server) + Spec *mcp.Tool + UnmarshalArgs func(content string) (any, error) + UnmarshalResult func(content string) (any, error) + func (t *CompiledTool) AsProto() (*aiv1.Tool, error) + type CompleteOptions struct + MaxIterations int + Messages []*aiv1.CompletionMessage + Tools []string + UnwrapCall bool + type CreateChart struct + Runtime *runtime.Runtime + func (t *CreateChart) CheckAccess(ctx context.Context) (bool, error) + func (t *CreateChart) Handler(ctx context.Context, args CreateChartArgs) (*CreateChartResult, error) + func (t *CreateChart) Spec() *mcp.Tool + type CreateChartArgs map[string]any + type CreateChartResult struct + ChartType string + Message string + Spec map[string]any + type DevelopMetricsView struct + Runtime *runtime.Runtime + func (t *DevelopMetricsView) CheckAccess(ctx context.Context) (bool, error) + func (t *DevelopMetricsView) Handler(ctx context.Context, args *DevelopMetricsViewArgs) (*DevelopMetricsViewResult, error) + func (t *DevelopMetricsView) Spec() *mcp.Tool + type DevelopMetricsViewArgs struct + Model string + Path string + Prompt string + type DevelopMetricsViewResult struct + MetricsViewName string + type DevelopModel struct + Runtime *runtime.Runtime + func (t *DevelopModel) CheckAccess(ctx context.Context) (bool, error) + func (t *DevelopModel) Handler(ctx context.Context, args *DevelopModelArgs) (*DevelopModelResult, error) + func (t *DevelopModel) Spec() *mcp.Tool + type DevelopModelArgs struct + Path string + Prompt string + type DevelopModelResult struct + ModelName string + type DeveloperAgent struct + Runtime *runtime.Runtime + func (t *DeveloperAgent) CheckAccess(ctx context.Context) (bool, error) + func (t *DeveloperAgent) Handler(ctx context.Context, args *DeveloperAgentArgs) (*DeveloperAgentResult, error) + func (t *DeveloperAgent) Spec() *mcp.Tool + type DeveloperAgentArgs struct + CurrentFilePath string + InitProject bool + Prompt string + type DeveloperAgentResult struct + Response string + type GetMetricsView struct + Runtime *runtime.Runtime + func (t *GetMetricsView) CheckAccess(ctx context.Context) (bool, error) + func (t *GetMetricsView) Handler(ctx context.Context, args *GetMetricsViewArgs) (*GetMetricsViewResult, error) + func (t *GetMetricsView) Spec() *mcp.Tool + type GetMetricsViewArgs struct + MetricsView string + type GetMetricsViewResult struct + Spec map[string]any + type InternalError struct + func (e InternalError) Error() string + type LLMMarshaler interface + ToLLM func() *aiv1.ContentBlock + type ListFiles struct + Runtime *runtime.Runtime + func (t *ListFiles) CheckAccess(ctx context.Context) (bool, error) + func (t *ListFiles) Handler(ctx context.Context, args *ListFilesArgs) (*ListFilesResult, error) + func (t *ListFiles) Spec() *mcp.Tool + type ListFilesArgs struct + type ListFilesResult struct + Files []map[string]any + type ListMetricsViews struct + Runtime *runtime.Runtime + func (t *ListMetricsViews) CheckAccess(ctx context.Context) (bool, error) + func (t *ListMetricsViews) Handler(ctx context.Context, args *ListMetricsViewsArgs) (*ListMetricsViewsResult, error) + func (t *ListMetricsViews) Spec() *mcp.Tool + type ListMetricsViewsArgs struct + type ListMetricsViewsResult struct + MetricsViews []map[string]any + type Message struct + Content string + ContentType MessageContentType + ID string + Index int + ParentID string + Role Role + SessionID string + Time time.Time + Tool string + Type MessageType + type MessageContentType string + const MessageContentTypeError + const MessageContentTypeJSON + const MessageContentTypeText + type MessageType string + const MessageTypeCall + const MessageTypeProgress + const MessageTypeResult + type Predicate func(*Message) bool + func FilterByID(id string) Predicate + func FilterByParent(parentID string) Predicate + func FilterByRoot() Predicate + func FilterByTool(tool string) Predicate + func FilterByType(typ MessageType) Predicate + type QueryMetricsView struct + Runtime *runtime.Runtime + func (t *QueryMetricsView) CheckAccess(ctx context.Context) (bool, error) + func (t *QueryMetricsView) Handler(ctx context.Context, args QueryMetricsViewArgs) (*QueryMetricsViewResult, error) + func (t *QueryMetricsView) Spec() *mcp.Tool + type QueryMetricsViewArgs map[string]any + type QueryMetricsViewResult struct + Data []map[string]any + OpenURL string + type QueryMetricsViewSummary struct + Runtime *runtime.Runtime + func (t *QueryMetricsViewSummary) CheckAccess(ctx context.Context) (bool, error) + func (t *QueryMetricsViewSummary) Handler(ctx context.Context, args *QueryMetricsViewSummaryArgs) (*QueryMetricsViewSummaryResult, error) + func (t *QueryMetricsViewSummary) Spec() *mcp.Tool + type QueryMetricsViewSummaryArgs struct + MetricsView string + type QueryMetricsViewSummaryResult struct + Data map[string]any + type ReadFile struct + Runtime *runtime.Runtime + func (t *ReadFile) CheckAccess(ctx context.Context) (bool, error) + func (t *ReadFile) Handler(ctx context.Context, args *ReadFileArgs) (*ReadFileResult, error) + func (t *ReadFile) Spec() *mcp.Tool + type ReadFileArgs struct + Path string + type ReadFileResult struct + Contents string + type Role string + const RoleAssistant + const RoleSystem + const RoleTool + const RoleUser + type RouterAgent struct + Runtime *runtime.Runtime + func (t *RouterAgent) CheckAccess(ctx context.Context) (bool, error) + func (t *RouterAgent) Handler(ctx context.Context, args *RouterAgentArgs) (*RouterAgentResult, error) + func (t *RouterAgent) Spec() *mcp.Tool + type RouterAgentArgs struct + Agent string + AnalystAgentArgs *AnalystAgentArgs + DeveloperAgentArgs *DeveloperAgentArgs + Prompt string + SkipHandoff bool + type RouterAgentResult struct + Agent string + Response string + type Runner struct + Activity *activity.Client + Runtime *runtime.Runtime + Tools map[string]*CompiledTool + func NewRunner(rt *runtime.Runtime, activity *activity.Client) *Runner + func (r *Runner) Session(ctx context.Context, opts *SessionOptions) (res *Session, resErr error) + type SearchFiles struct + Runtime *runtime.Runtime + func (t *SearchFiles) CheckAccess(ctx context.Context) (bool, error) + func (t *SearchFiles) Handler(ctx context.Context, args *SearchFilesArgs) (*SearchFilesResult, error) + func (t *SearchFiles) Spec() *mcp.Tool + type SearchFilesArgs struct + CaseSensitive bool + GlobPattern string + Pattern string + type SearchFilesResult struct + Matches []SearchMatch + type SearchMatch struct + Lines []int + Path string + Snippets []string + type Session struct + ParentID string + func GetSession(ctx context.Context) *Session + func (s *Session) AddMessage(opts *AddMessageOptions) *Message + func (s *Session) Call(ctx context.Context, opts *CallOptions) (*CallResult, error) + func (s *Session) CallTool(ctx context.Context, role Role, toolName string, out, args any) (*CallResult, error) + func (s *Session) CallToolWithOptions(ctx context.Context, opts *CallToolOptions) (*CallResult, error) + func (s *Session) Complete(ctx context.Context, name string, out any, opts *CompleteOptions) error + func (s *Session) MCPServer(ctx context.Context) *mcp.Server + func (s *Session) NewCompletionMessage(m *Message) (*aiv1.CompletionMessage, error) + func (s *Session) NewCompletionMessages(msgs []*Message) []*aiv1.CompletionMessage + func (s *Session) RootID() string + func (s *Session) Tool(toolName string) (*CompiledTool, bool) + func (s *Session) UnmarshalMessageContent(m *Message) (any, error) + type SessionOptions struct + Claims *runtime.SecurityClaims + CreateIfNotExists bool + InstanceID string + SessionID string + UserAgent string + type Tool interface + CheckAccess func(context.Context) (bool, error) + Handler func(ctx context.Context, args In) (Out, error) + Spec func() *mcp.Tool + type WriteFile struct + Runtime *runtime.Runtime + func (t *WriteFile) CheckAccess(ctx context.Context) (bool, error) + func (t *WriteFile) Handler(ctx context.Context, args *WriteFileArgs) (*WriteFileResult, error) + func (t *WriteFile) Spec() *mcp.Tool + type WriteFileArgs struct + Contents string + Path string + Remove bool + type WriteFileResult struct + Diff string + IsNewFile bool + ParseError string + Resources []map[string]any
Go to main page