Versions in this module Expand all Collapse all v0 v0.12.2 Feb 12, 2026 v0.12.2-rc.175399a Feb 12, 2026 v0.12.1 Feb 12, 2026 v0.12.1-rc.d72b481 Feb 12, 2026 v0.12.0 Jan 23, 2026 Changes in this version + type Algorithm struct + Created pgtype.Timestamp + Description string + ID int64 + Name string + ProcessorID int64 + ResultType ResultType + Version string + WindowTypeID int64 + type AlgorithmDependency struct + Created pgtype.Timestamp + FromAlgorithmID int64 + FromProcessorID int64 + FromWindowTypeID int64 + ID int64 + LookbackCount int64 + LookbackTimedelta int64 + ToAlgorithmID int64 + ToProcessorID int64 + ToWindowTypeID int64 + type AlgorithmExecutionPath struct + AlgoIDPath string + FinalAlgoID int64 + LookbackCountPath string + LookbackTimedeltaPath string + NumDependencies int32 + ProcIDPath string + WindowTypeIDPath string + type Annotation struct + CreatedAt pgtype.Timestamp + Description pgtype.Text + ID int64 + Metadata []byte + TimeFrom pgtype.Timestamp + TimeTo pgtype.Timestamp + type AnnotationAlgorithm struct + AlgorithmID int64 + AnnotationID int64 + type AnnotationWindowType struct + AnnotationID int64 + WindowTypeID int64 + type CreateAlgorithmDependencyParams struct + FromAlgorithmName string + FromAlgorithmVersion string + FromProcessorName string + FromProcessorRuntime string + LookbackCount int64 + LookbackTimedelta int64 + ToAlgorithmName string + ToAlgorithmVersion string + ToProcessorName string + ToProcessorRuntime string + type CreateAlgorithmParams struct + Description string + Name string + ProcessorName string + ProcessorRuntime string + ResultType ResultType + Version string + WindowTypeName string + WindowTypeVersion string + type CreateMetadataFieldParams struct + Description string + Name string + type CreateProcessorParams struct + ConnectionString string + Name string + ProjectName pgtype.Text + Runtime string + type CreateResultParams struct + AlgorithmID pgtype.Int8 + ResultArray []float64 + ResultJson []byte + ResultValue pgtype.Float8 + WindowTypeID pgtype.Int8 + WindowsID pgtype.Int8 + type CreateWindowTypeMetadataFieldBridgeParams struct + MetadataFieldsID int64 + WindowTypeID int64 + type CreateWindowTypeParams struct + Description string + Name string + Version string + type DBTX interface + Exec func(context.Context, string, ...interface{}) (pgconn.CommandTag, error) + Query func(context.Context, string, ...interface{}) (pgx.Rows, error) + QueryRow func(context.Context, string, ...interface{}) pgx.Row + type Datalayer struct + func NewClient(ctx context.Context, connStr string) (*Datalayer, error) + func (d *Datalayer) EmitWindow(ctx context.Context, window *pb.Window) (pb.WindowEmitStatus, error) + func (d *Datalayer) Expose(ctx context.Context, settings *pb.ExposeSettings) (*pb.InternalState, error) + func (d *Datalayer) RegisterProcessor(ctx context.Context, proc *pb.ProcessorRegistration) error + func (d *Datalayer) WithTx(ctx context.Context) (types.Tx, error) + type MetadataField struct + Description string + ID int64 + Name string + type MetadataFieldsReference struct + MetadataFieldsID int64 + WindowTypeID int64 + type NullResultType struct + ResultType ResultType + Valid bool + func (ns *NullResultType) Scan(value interface{}) error + func (ns NullResultType) Value() (driver.Value, error) + type PgTx struct + func (t *PgTx) Commit(ctx context.Context) error + func (t *PgTx) Rollback(ctx context.Context) + type Processor struct + ConnectionString string + Created pgtype.Timestamp + ID int64 + Name string + ProjectName pgtype.Text + Runtime string + type Queries struct + func New(db DBTX) *Queries + func (q *Queries) CreateAlgorithm(ctx context.Context, arg CreateAlgorithmParams) error + func (q *Queries) CreateAlgorithmDependency(ctx context.Context, arg CreateAlgorithmDependencyParams) error + func (q *Queries) CreateMetadataField(ctx context.Context, arg CreateMetadataFieldParams) (int64, error) + func (q *Queries) CreateProcessor(ctx context.Context, arg CreateProcessorParams) error + func (q *Queries) CreateResult(ctx context.Context, arg CreateResultParams) (int64, error) + func (q *Queries) CreateWindowType(ctx context.Context, arg CreateWindowTypeParams) (int64, error) + func (q *Queries) CreateWindowTypeMetadataFieldBridge(ctx context.Context, arg CreateWindowTypeMetadataFieldBridgeParams) error + func (q *Queries) ReadAlgorithmExecutionPaths(ctx context.Context, windowTypeID string) ([]AlgorithmExecutionPath, error) + func (q *Queries) ReadAlgorithmExecutionPathsForAlgo(ctx context.Context, algoID int64) ([]AlgorithmExecutionPath, error) + func (q *Queries) ReadAlgorithmId(ctx context.Context, arg ReadAlgorithmIdParams) (int64, error) + func (q *Queries) ReadAlgorithms(ctx context.Context) ([]Algorithm, error) + func (q *Queries) ReadAlgorithmsForProcessorId(ctx context.Context, processorID int64) ([]Algorithm, error) + func (q *Queries) ReadAlgorithmsForWindow(ctx context.Context, arg ReadAlgorithmsForWindowParams) ([]Algorithm, error) + func (q *Queries) ReadFromAlgorithmDependencies(ctx context.Context, arg ReadFromAlgorithmDependenciesParams) ([]AlgorithmDependency, error) + func (q *Queries) ReadMetadataFields(ctx context.Context) ([]MetadataField, error) + func (q *Queries) ReadMetadataFieldsByWindowType(ctx context.Context, arg ReadMetadataFieldsByWindowTypeParams) ([]ReadMetadataFieldsByWindowTypeRow, error) + func (q *Queries) ReadProcessorExcludeProject(ctx context.Context, projectName pgtype.Text) ([]Processor, error) + func (q *Queries) ReadProcessors(ctx context.Context) ([]Processor, error) + func (q *Queries) ReadProcessorsByIDs(ctx context.Context, processorIds []int64) ([]Processor, error) + func (q *Queries) ReadResultsForAlgorithmByCount(ctx context.Context, arg ReadResultsForAlgorithmByCountParams) ([]ReadResultsForAlgorithmByCountRow, error) + func (q *Queries) ReadResultsForAlgorithmByTimedelta(ctx context.Context, arg ReadResultsForAlgorithmByTimedeltaParams) ([]ReadResultsForAlgorithmByTimedeltaRow, error) + func (q *Queries) ReadWindowTypeMetadataFields(ctx context.Context) ([]WindowTypeMetadataField, error) + func (q *Queries) ReadWindowTypes(ctx context.Context) ([]WindowType, error) + func (q *Queries) RegisterWindow(ctx context.Context, arg RegisterWindowParams) (RegisterWindowRow, error) + func (q *Queries) WithTx(tx pgx.Tx) *Queries + type ReadAlgorithmIdParams struct + AlgorithmName string + AlgorithmVersion string + ProcessorName string + ProcessorRuntime string + type ReadAlgorithmsForWindowParams struct + WindowTypeName string + WindowTypeVersion string + type ReadFromAlgorithmDependenciesParams struct + FromAlgorithmName string + FromAlgorithmVersion string + FromProcessorName string + FromProcessorRuntime string + type ReadMetadataFieldsByWindowTypeParams struct + WindowTypeName string + WindowTypeVersion string + type ReadMetadataFieldsByWindowTypeRow struct + MetadataFieldDescription string + MetadataFieldID int64 + MetadataFieldName string + type ReadResultsForAlgorithmByCountParams struct + AlgorithmID pgtype.Int8 + Count int32 + SearchTo pgtype.Timestamp + type ReadResultsForAlgorithmByCountRow struct + AlgorithmID pgtype.Int8 + ResultArray []float64 + ResultID int64 + ResultJson []byte + ResultValue pgtype.Float8 + WindowID int64 + WindowMetadata []byte + WindowOrigin string + WindowTimeFrom pgtype.Timestamp + WindowTimeTo pgtype.Timestamp + WindowTypeName string + WindowTypeVersion string + type ReadResultsForAlgorithmByTimedeltaParams struct + AlgorithmID pgtype.Int8 + SearchFrom pgtype.Timestamp + SearchTo pgtype.Timestamp + type ReadResultsForAlgorithmByTimedeltaRow struct + AlgorithmID pgtype.Int8 + ResultArray []float64 + ResultID int64 + ResultJson []byte + ResultValue pgtype.Float8 + WindowID int64 + WindowMetadata []byte + WindowOrigin string + WindowTimeFrom pgtype.Timestamp + WindowTimeTo pgtype.Timestamp + WindowTypeName string + WindowTypeVersion string + type RegisterWindowParams struct + Metadata []byte + Origin string + TimeFrom pgtype.Timestamp + TimeTo pgtype.Timestamp + WindowTypeName string + WindowTypeVersion string + type RegisterWindowRow struct + ID int64 + WindowTypeID int64 + type Result struct + AlgorithmID pgtype.Int8 + ID int64 + ResultArray []float64 + ResultJson []byte + ResultValue pgtype.Float8 + WindowTypeID pgtype.Int8 + WindowsID pgtype.Int8 + type ResultType string + const ResultTypeArray + const ResultTypeNone + const ResultTypeStruct + const ResultTypeValue + func (e *ResultType) Scan(src interface{}) error + type Window struct + Created pgtype.Timestamp + ID int64 + Metadata []byte + Origin string + TimeFrom pgtype.Timestamp + TimeTo pgtype.Timestamp + WindowTypeID int64 + type WindowType struct + Created pgtype.Timestamp + Description string + ID int64 + Name string + Version string + type WindowTypeMetadataField struct + MetadataFieldDescription string + MetadataFieldID int64 + MetadataFieldName string + WindowTypeName string + WindowTypeVersion string v0.12.0-rc.f274df6 Jan 23, 2026 v0.12.0-rc.96c968f Jan 23, 2026
Go to main page