Versions in this module Expand all Collapse all v0 v0.79.5 Jan 22, 2026 v0.79.4 Jan 19, 2026 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