inference

package
v0.11.809 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 4, 2026 License: Apache-2.0 Imports: 48 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ValidateAsset

func ValidateAsset(asset *pipeline.Asset) error

ValidateAsset validates the first-version inference contract without making requests.

func ValidateQualityCheckPlatform added in v0.11.802

func ValidateQualityCheckPlatform(asset *pipeline.Asset, connectionType string) error

ValidateQualityCheckPlatform rejects quality checks on an asset whose connection type is unknown or has no check executor. Checks run on the platform of the `destination` inferred from the connection, as for ingestr.

Types

type Client

type Client struct {
	Provider        string
	Model           string
	APIKey          string
	MaxOutputTokens int
	HTTPClient      *http.Client
	OnCacheUsage    func(readTokens, writtenTokens int64)
}

Client calls a supported inference provider.

func (*Client) CompleteStructured

func (c *Client) CompleteStructured(ctx context.Context, state, instructions string, columns []outputColumn) (map[string]any, error)

CompleteStructured asks the provider for one schema-constrained object and validates the object before returning it. Configuration and credentials must already have been validated by readConfig and resolveGroups.

type Operator

type Operator struct {
	// contains filtered or unexported fields
}

Operator enriches query results and publishes them through Bruin's ingestr writer.

func (*Operator) Run

Jump to

Keyboard shortcuts

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