daguito

package module

Go to main page

Versions in this module

v0

v0.5.8

Jun 15, 2026

Changes in this version

type AudioStreamSession

+ func (s *AudioStreamSession) Pause(ctx context.Context) error

+ func (s *AudioStreamSession) Resume(ctx context.Context) error

+ func (s *AudioStreamSession) SendControl(ctx context.Context, control string) error

type FlowGraph

+ CoalesceEnabled *bool

v0.5.7

Jun 13, 2026

Changes in this version

+ const DefaultAPIURL

v0.5.6

Jun 12, 2026

Changes in this version

type SendableMessage

+ MediaURL string

+ func MediaURLMessage(kind MediaKind, key, mediaURL, mimeType string, sizeBytes int64, text string) SendableMessage

v0.5.5

Jun 8, 2026

Changes in this version

+ type WebhookRunStreamInput struct

+ APIURL string

+ Input map[string]any

+ SessionKey string

+ Text string

+ Timeout time.Duration

+ Token string

+ WebhookID string

+ type WebhookRunStreamResult struct

+ ElapsedMs int64

+ ExecutionID string

+ OK bool

+ Output any

+ Status string

+ func RunWebhookStream(ctx context.Context, input WebhookRunStreamInput) (*WebhookRunStreamResult, error)

v0.5.4

May 31, 2026

Changes in this version

type AgentFlowSpec

+ CoalesceEnabled *bool

v0.5.3

May 26, 2026

v0.5.2

May 26, 2026

Changes in this version

+ type AnalyticsService struct

+ func (s *AnalyticsService) GetOrg(ctx context.Context) (*OrgAnalytics, error)

type Client

+ Models *ModelsService

+ type CreateKnowledgeSourceInput struct

+ Description string

+ Kind string

+ Name string

+ OrgID string

+ type DeleteChunksByMetadataInput struct

+ MetadataKey string

+ MetadataValue string

+ type DeleteChunksByMetadataResult struct

+ DeletedCount int

type FlowToolRef

+ RequiresData *RequiresData

+ type IngestJob struct

+ JobID string

+ OrgID string

+ Raw map[string]any

+ Status string

+ func (j *IngestJob) UnmarshalJSON(data []byte) error

+ type IngestTextAdminInput struct

+ Metadata map[string]any

+ Text string

+ type IngestURLInput struct

+ Metadata map[string]any

+ URL string

+ type KnowledgeBase struct

+ Description *string

+ Dim int

+ EmbeddingModel string

+ EmbeddingProvider string

+ ID string

+ Name string

+ TenancyTier string

+ type KnowledgeService struct

+ func (s *KnowledgeService) CreateSource(ctx context.Context, in CreateKnowledgeSourceInput) (*KnowledgeSource, error)

+ func (s *KnowledgeService) DeleteChunksByMetadata(ctx context.Context, sourceID string, in DeleteChunksByMetadataInput) (*DeleteChunksByMetadataResult, error)

+ func (s *KnowledgeService) DeleteSource(ctx context.Context, sourceID string) error

+ func (s *KnowledgeService) GetIngestJob(ctx context.Context, jobID string) (*IngestJob, error)

+ func (s *KnowledgeService) IngestText(ctx context.Context, sourceID string, in IngestTextAdminInput) (*IngestJob, error)

+ func (s *KnowledgeService) IngestURL(ctx context.Context, sourceID string, in IngestURLInput) (*IngestJob, error)

+ func (s *KnowledgeService) ListBases(ctx context.Context, opts ListKnowledgeOptions) ([]KnowledgeBase, error)

+ func (s *KnowledgeService) ListSources(ctx context.Context, opts ListKnowledgeOptions) ([]KnowledgeSource, error)

+ func (s *KnowledgeService) UpdateChunksMetadata(ctx context.Context, sourceID string, in UpdateChunksMetadataInput) (*UpdateChunksMetadataResult, error)

+ type KnowledgeSource struct

+ ChunkCount int

+ CreatedAt string

+ Description *string

+ ID string

+ KbID string

+ Kind string

+ Name string

+ OrgID string

+ SourceCount int

+ Status string

+ TokenCount int

+ UpdatedAt string

+ type ListKnowledgeOptions struct

+ OrgID string

+ type Model struct

+ DisplayName string

+ ID string

+ Provider string

+ Tier string

+ type ModelsService struct

+ func (s *ModelsService) List(ctx context.Context) ([]Model, error)

+ type NodeCatalog = map[string]any

+ type NodesService struct

+ func (s *NodesService) GetCatalog(ctx context.Context) (NodeCatalog, error)

+ type OrgAnalytics struct

+ Budget OrgBudgetSnapshot

+ HTTPToday OrgHTTPUsage

+ LLMToday OrgLLMUsage

+ MessagesToday OrgMessagesUsage

+ OrgID string

+ type OrgBudgetSnapshot struct

+ KeyCapMicroUsd *int64

+ KeyMtdMicroUsd int64

+ OrgCapMicroUsd *int64

+ OrgMtdMicroUsd int64

+ type OrgHTTPUsage struct

+ ByPath map[string]int

+ Total int

+ type OrgLLMUsage struct

+ CostUSD float64

+ Requests int

+ Tokens int

+ type OrgMessagesUsage struct

+ Inbound map[string]int

+ OutboundLast24h int

+ type RequiresData struct

+ KBScope bool

+ type UpdateChunksMetadataInput struct

+ Match UpdateChunksMetadataMatch

+ Patch map[string]any

+ type UpdateChunksMetadataMatch struct

+ MetadataKey string

+ MetadataValue string

+ type UpdateChunksMetadataResult struct

+ UpdatedCount int

type WebhookStreamOptions

+ AutoReconnect bool

v0.5.1

May 24, 2026

v0.4.3

May 20, 2026

Changes in this version

type Client

+ Templates *TemplatesService

+ type TemplateFieldDetail struct

+ Description string

+ EnumValues []string

+ Name string

+ Type string

+ type TemplatePreviewExample struct

+ Extracted map[string]any

+ Model string

+ Transcript string

+ TranscriptOrigin string

+ type TemplatePreviewInput struct

+ ForceRegenerate bool

+ Model string

+ TemplateBody string

+ Vertical string

+ type TemplatePreviewResult struct

+ BodyHash string

+ Example *TemplatePreviewExample

+ FieldCount int

+ FieldNames []string

+ FieldsDetail []TemplateFieldDetail

+ TemplateSchema TemplateSchema

+ Warnings []TemplatePreviewWarning

+ type TemplatePreviewWarning struct

+ Code string

+ Field string

+ Hint string

+ Message string

+ type TemplateSchema struct

+ Name string

+ Schema map[string]any

+ type TemplatesService struct

+ func (s *TemplatesService) Preview(ctx context.Context, in TemplatePreviewInput) (*TemplatePreviewResult, error)

v0.4.1

May 18, 2026

Changes in this version

+ type FlowGraph struct

+ Edges []FlowGraphEdge

+ Nodes []FlowGraphNode

+ type FlowGraphEdge struct

+ ID string

+ Source string

+ SourceHandle string

+ Target string

+ type FlowGraphNode struct

+ Config map[string]any

+ ID string

+ Kind string

+ Position *FlowNodePos

+ Type string

+ type FlowNodePos struct

+ X float64

+ Y float64

+ type FlowResult struct

+ Created bool

+ FlowID string

+ Name string

+ Slug string

+ WebhookID string

+ type FlowSpec struct

+ Graph FlowGraph

+ Name string

+ Slug string

+ TriggerType string

type FlowsService

+ func (s *FlowsService) UpsertFlow(ctx context.Context, spec FlowSpec) (*FlowResult, error)

v0.4.0

May 16, 2026

Changes in this version

type FlowsService

+ func (s *FlowsService) ResolveWebhook(ctx context.Context, slug string) (*ResolvedFlowWebhook, error)

+ type ResolvedFlowWebhook struct

+ FlowID string

+ Name string

+ Slug string

+ WebhookID string

+ WebhookToken string

v0.3.0

May 15, 2026

Changes in this version

+ var ErrAdmin = errors.New("daguito: admin request failed")

+ var ErrAudioStream = errors.New("audio stream")

+ var SupportedAudioCodecs = []string

+ var Version = "0.3.0"

+ func Int64Ptr(v int64) *int64

+ type AccountKey struct

+ CreatedAt string

+ CurrentMtdMicroUsd int64

+ ID string

+ KeyPrefix string

+ LastUsedAt *string

+ MonthlyBudgetMicroUsd *int64

+ Name string

+ RevokedAt *string

+ type AccountKeyCreated struct

+ Plaintext string

+ type AccountKeysService struct

+ func (s *AccountKeysService) Create(ctx context.Context, in CreateAccountKeyInput) (*AccountKeyCreated, error)

+ func (s *AccountKeysService) List(ctx context.Context) ([]AccountKey, error)

+ func (s *AccountKeysService) Revoke(ctx context.Context, keyID string) error

+ func (s *AccountKeysService) SetBudget(ctx context.Context, keyID string, monthlyBudgetMicroUsd *int64) (*AccountKey, error)

+ type AgentFlowResult struct

+ Created bool

+ FlowID string

+ Name string

+ Slug string

+ WebhookID string

+ type AgentFlowSpec struct

+ ContextMemoryKeys []string

+ HistoryTurns *int

+ MaxTokens *int

+ MaxToolIterations *int

+ MemoryFactsSchema any

+ MemorySummaryConfig any

+ Model string

+ Name string

+ Provider string

+ RecentTurns *int

+ Slug string

+ SystemPrompt string

+ Temperature *float64

+ Tools []FlowToolRef

+ type AudioStreamOptions struct

+ APIURL string

+ Codec string

+ ReadyTimeout time.Duration

+ SampleRate int

+ SessionID string

+ Token string

+ type AudioStreamReady struct

+ Codec string

+ Guards map[string]any

+ SessionKey string

+ type AudioStreamSession struct

+ func NewAudioStreamSession(opts AudioStreamOptions) *AudioStreamSession

+ func (s *AudioStreamSession) Close() error

+ func (s *AudioStreamSession) Connect(ctx context.Context) error

+ func (s *AudioStreamSession) Ready() *AudioStreamReady

+ func (s *AudioStreamSession) SendAudio(ctx context.Context, chunk []byte) error

+ func (s *AudioStreamSession) SessionID() string

+ type BudgetsService struct

+ func (s *BudgetsService) GetOrg(ctx context.Context) (*OrgBudget, error)

+ func (s *BudgetsService) SetOrg(ctx context.Context, monthlyBudgetMicroUsd *int64) (*OrgBudget, error)

+ type Client struct

+ APIKey string

+ APIURL string

+ AccountKeys *AccountKeysService

+ Budgets *BudgetsService

+ Flows *FlowsService

+ PublicKeys *PublicKeysService

+ func NewClient(opts ClientOptions) (*Client, error)

+ type ClientOptions struct

+ APIKey string

+ APIURL string

+ HTTPClient *http.Client

+ type CreateAccountKeyInput struct

+ MonthlyBudgetMicroUsd *int64

+ Name string

+ type CreatePublicKeyInput struct

+ AllowedOrigins []string

+ MonthlyBudgetMicroUsd *int64

+ Name string

+ type FlowToolRef struct

+ Config map[string]any

+ Kind string

+ Name string

+ type FlowsService struct

+ func (s *FlowsService) UpsertAgent(ctx context.Context, spec AgentFlowSpec) (*AgentFlowResult, error)

+ type OrgBudget struct

+ CurrentMtdMicroUsd int64

+ MonthlyBudgetMicroUsd *int64

+ MtdResetAt *string

+ type PublicKey struct

+ AllowedOrigins []string

+ CreatedAt string

+ CurrentMtdMicroUsd int64

+ FlowID string

+ ID string

+ KeyPrefix string

+ LastUsedAt *string

+ MonthlyBudgetMicroUsd *int64

+ Name string

+ RevokedAt *string

+ type PublicKeyCreated struct

+ Plaintext string

+ type PublicKeysService struct

+ func (s *PublicKeysService) Create(ctx context.Context, flowID string, in CreatePublicKeyInput) (*PublicKeyCreated, error)

+ func (s *PublicKeysService) List(ctx context.Context, flowID string) ([]PublicKey, error)

+ func (s *PublicKeysService) Revoke(ctx context.Context, flowID, keyID string) error

+ func (s *PublicKeysService) SetBudget(ctx context.Context, flowID, keyID string, monthlyBudgetMicroUsd *int64) (*PublicKey, error)

v0.1.0

May 14, 2026

Changes in this version

+ var ErrInvalidToken = errors.New("daguito: invalid token")

+ var ErrKnowledge = errors.New("daguito: knowledge request failed")

+ var ErrStream = errors.New("daguito: stream session error")

+ var ErrUploadFailed = errors.New("daguito: upload failed")

+ var ErrWebhook = errors.New("daguito: webhook request failed")

+ type ClosedEvent struct

+ Code int

+ Reason string

+ type ErrorEvent struct

+ Message string

+ type EventType string

+ const EventClosed

+ const EventError

+ const EventFlowCompleted

+ const EventFlowFailed

+ const EventNodeCompleted

+ const EventNodeEmit

+ const EventNodeFailed

+ const EventNodeStarted

+ const EventNodeToken

+ const EventReady

+ type FlowCompletedEvent struct

+ ElapsedMs int

+ Output any

+ type FlowFailedEvent struct

+ Error string

+ type IngestTextInput struct

+ Metadata map[string]any

+ SourceID string

+ Text string

+ type IngestTextResult struct

+ ChunkCount int

+ SourceID string

+ TokenCount int

+ type KnowledgeSession struct

+ func NewKnowledgeSession(opts KnowledgeSessionOptions) *KnowledgeSession

+ func (s *KnowledgeSession) IngestText(ctx context.Context, in IngestTextInput) (*IngestTextResult, error)

+ func (s *KnowledgeSession) Search(ctx context.Context, in SearchInput) (*SearchResult, error)

+ type KnowledgeSessionOptions struct

+ APIKey string

+ APIURL string

+ DefaultSourceID string

+ HTTPClient *http.Client

+ Timeout time.Duration

+ type MediaKind string

+ const MediaKindAudio

+ const MediaKindDocument

+ const MediaKindImage

+ const MediaKindVideo

+ type NodeCompletedEvent struct

+ DurationMs int

+ NodeID string

+ Output any

+ type NodeEmitEvent struct

+ Data map[string]any

+ Kind string

+ NodeID string

+ type NodeFailedEvent struct

+ Error string

+ NodeID string

+ type NodeStartedEvent struct

+ NodeID string

+ type NodeTokenEvent struct

+ NodeID string

+ Text string

+ type ReadyEvent struct

+ WebhookID string

+ type SearchHit struct

+ Content string

+ ID string

+ Metadata map[string]any

+ Score float64

+ SourceID string

+ type SearchInput struct

+ EnableCache *bool

+ EnableRerank *bool

+ EnableRewrite *bool

+ Query string

+ SourceIDs []string

+ TopK *int

+ type SearchResult struct

+ Hits []SearchHit

+ QueryOriginal string

+ QueryRewritten string

+ Raw map[string]any

+ type SendableMessage struct

+ FormID string

+ ImageURL string

+ ImageURLs []string

+ Kind string

+ MediaKey string

+ MimeType string

+ Payload map[string]any

+ SizeBytes int64

+ Text string

+ func FormResponseMessage(formID string, payload map[string]any) SendableMessage

+ func ImageMultiMessage(imageURLs []string, text string) SendableMessage

+ func ImageURLMessage(imageURL, text string) SendableMessage

+ func MediaKeyMessage(kind MediaKind, mediaKey, mimeType string, sizeBytes int64, text string) SendableMessage

+ func TextMessage(text string) SendableMessage

+ type StreamEvent struct

+ Closed *ClosedEvent

+ Error *ErrorEvent

+ FlowCompleted *FlowCompletedEvent

+ FlowFailed *FlowFailedEvent

+ NodeCompleted *NodeCompletedEvent

+ NodeEmit *NodeEmitEvent

+ NodeFailed *NodeFailedEvent

+ NodeStarted *NodeStartedEvent

+ NodeToken *NodeTokenEvent

+ Ready *ReadyEvent

+ Type EventType

+ type ToolHandler func(ctx context.Context, args json.RawMessage) (any, error)

+ type ToolProgressEvent struct

+ Attempt int

+ Progress float64

+ Resource *ToolProgressResource

+ Result *ToolProgressResult

+ Stage string

+ Tool string

+ TraceID string

+ func ParseToolProgress(evt *NodeEmitEvent) *ToolProgressEvent

+ type ToolProgressItem struct

+ Snippet string

+ Title string

+ URL string

+ type ToolProgressResource struct

+ Kind string

+ MediaKey string

+ Name string

+ URL string

+ type ToolProgressResult struct

+ Items []ToolProgressItem

+ Summary string

+ type ToolSpec struct

+ Description string

+ Name string

+ Parameters map[string]any

+ TimeoutMS int

+ type UploadInput struct

+ APIURL string

+ Data []byte

+ Filename string

+ HTTPClient *http.Client

+ Kind MediaKind

+ MimeType string

+ Path string

+ Timeout time.Duration

+ Token string

+ WebhookID string

+ type UploadResult struct

+ ExpiresInSec int

+ MediaKey string

+ MimeType string

+ SizeBytes int64

+ func UploadFile(ctx context.Context, input UploadInput) (*UploadResult, error)

+ type WebhookRunInput struct

+ APIURL string

+ HTTPClient *http.Client

+ Input map[string]any

+ Timeout time.Duration

+ Token string

+ type WebhookRunResult struct

+ ExecutionID string

+ OK bool

+ Output any

+ Status string

+ func RunWebhook(ctx context.Context, input WebhookRunInput) (*WebhookRunResult, error)

+ type WebhookStreamOptions struct

+ APIURL string

+ BaseInput map[string]any

+ Scope map[string]any

+ SessionKey string

+ Token string

+ WebhookID string

+ type WebhookStreamSession struct

+ func NewWebhookStreamSession(opts WebhookStreamOptions) *WebhookStreamSession

+ func (s *WebhookStreamSession) Close() error

+ func (s *WebhookStreamSession) Connect(ctx context.Context) error

+ func (s *WebhookStreamSession) Events() <-chan StreamEvent

+ func (s *WebhookStreamSession) RegisterTool(spec ToolSpec, handler ToolHandler) error

+ func (s *WebhookStreamSession) Send(ctx context.Context, msg SendableMessage, baseInput map[string]any) error

+ func (s *WebhookStreamSession) SendRaw(ctx context.Context, frame map[string]any) error

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