Versions in this module Expand all Collapse all v0 v0.14.2 Apr 29, 2026 v0.14.1 Apr 29, 2026 v0.14.1-rc.43d8791 Apr 29, 2026 v0.14.0 Apr 29, 2026 Changes in this version + var AlgorithmExistsUnderDifferentProcessor = fmt.Errorf("algorithm exists under a different processor") + type Algorithm struct + Created pgtype.Timestamp + Description string + ID int64 + Name string + ProcessorID int64 + ResultType ResultType + SelfLookbackCount int64 + SelfLookbackGapCount int64 + SelfLookbackGapTimedelta int64 + SelfLookbackTimedelta int64 + Version string + WindowTypeID int64 + type AlgorithmDependency struct + Created pgtype.Timestamp + FromAlgorithmID int64 + FromProcessorID int64 + FromWindowTypeID int64 + ID int64 + LookbackCount int64 + LookbackGapCount int64 + LookbackGapTimedelta int64 + LookbackTimedelta int64 + ToAlgorithmID int64 + ToProcessorID int64 + ToWindowTypeID int64 + type AlgorithmExecutionPath struct + AlgoIDPath string + FinalAlgoID int64 + LookbackCountPath string + LookbackGapCountPath string + LookbackGapTimedeltaPath string + LookbackTimedeltaPath string + NumDependencies int32 + ProcIDPath string + SelfLookbackCountPath string + SelfLookbackGapCountPath string + SelfLookbackGapTimedeltaPath string + SelfLookbackTimedeltaPath string + WindowTypeIDPath string + type AlgorithmState string + const AlgorithmStateFAILEDHANDLED + const AlgorithmStateFAILEDUNHANDLED + const AlgorithmStatePENDING + const AlgorithmStatePROCESSING + const AlgorithmStateSUCCEEDED + func (e *AlgorithmState) Scan(src interface{}) error + 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 CircularDependencyError struct + FromAlgoName string + FromAlgoProcessor string + FromAlgoVersion string + ToAlgoName string + ToAlgoProcessor string + ToAlgoVersion string + func (c *CircularDependencyError) Error() string + type CreateAlgorithmDependencyParams struct + FromAlgorithmName string + FromAlgorithmVersion string + FromProcessorName string + FromProcessorRuntime string + LookbackCount int64 + LookbackGapCount int64 + LookbackGapTimedelta int64 + LookbackTimedelta int64 + ToAlgorithmName string + ToAlgorithmVersion string + ToProcessorName string + ToProcessorRuntime string + type CreateAlgorithmParams struct + Description string + Name string + ProcessorName string + ProcessorRuntime string + ResultType ResultType + SelfLookbackCount int64 + SelfLookbackGapCount int64 + SelfLookbackGapTimedelta int64 + SelfLookbackTimedelta int64 + Version string + WindowTypeName string + WindowTypeVersion string + type CreateMetadataFieldParams struct + Description string + Filter pgtype.Bool + Name string + type CreateProcessorParams struct + ConnectionString string + Name string + ProjectName pgtype.Text + Runtime string + type CreateResultParams struct + AlgorithmID pgtype.Int8 + 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, useTls bool) (_ pb.WindowEmitStatus, retErr error) + func (d *Datalayer) Expose(ctx context.Context, settings *pb.ExposeSettings) (_ *pb.InternalState, retErr error) + func (d *Datalayer) RegisterProcessor(ctx context.Context, proc *pb.ProcessorRegistration) (retErr error) + type FinaliseResultParams struct + Err []byte + ResultArray []float64 + ResultID int64 + ResultJson []byte + ResultValue pgtype.Float8 + State AlgorithmState + type Metadata struct + MetadataArray []float64 + MetadataJson []byte + MetadataKey string + MetadataValue pgtype.Float8 + WindowTypeID int64 + WindowsID int64 + type MetadataField struct + Description string + Filter pgtype.Bool + ID int64 + Name string + type MetadataFieldsReference struct + MetadataFieldsID int64 + WindowTypeID int64 + type MetadataFilter struct + Key string + Value any + type NullAlgorithmState struct + AlgorithmState AlgorithmState + Valid bool + func (ns *NullAlgorithmState) Scan(value interface{}) error + func (ns NullAlgorithmState) Value() (driver.Value, error) + type NullResultType struct + ResultType ResultType + Valid bool + func (ns *NullResultType) Scan(value interface{}) error + func (ns NullResultType) Value() (driver.Value, error) + type NullWindowState struct + Valid bool + WindowState WindowState + func (ns *NullWindowState) Scan(value interface{}) error + func (ns NullWindowState) 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) FinaliseResult(ctx context.Context, arg FinaliseResultParams) 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, windowTypeID int64) ([]MetadataField, 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) ReadWindowTypesByName(ctx context.Context, arg ReadWindowTypesByNameParams) ([]WindowType, error) + func (q *Queries) RegisterMetadata(ctx context.Context, arg RegisterMetadataParams) error + func (q *Queries) RegisterWindow(ctx context.Context, arg RegisterWindowParams) (RegisterWindowRow, error) + func (q *Queries) UpdateResultState(ctx context.Context, arg UpdateResultStateParams) error + func (q *Queries) UpdateWindowState(ctx context.Context, arg UpdateWindowStateParams) 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 ReadResultsForAlgorithmByCountParams struct + AlgorithmID pgtype.Int8 + CountOffset int32 + Limit pgtype.Int4 + MetadataFilters []byte + SearchTo pgtype.Timestamp + type ReadResultsForAlgorithmByCountRow struct + AlgorithmID pgtype.Int8 + ResultArray []float64 + ResultID int64 + ResultJson []byte + ResultType ResultType + 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 + CountOffset int32 + Limit pgtype.Int4 + MetadataFilters []byte + SearchFrom pgtype.Timestamp + SearchTo pgtype.Timestamp + type ReadResultsForAlgorithmByTimedeltaRow struct + AlgorithmID pgtype.Int8 + ResultArray []float64 + ResultID int64 + ResultJson []byte + ResultType ResultType + ResultValue pgtype.Float8 + WindowID int64 + WindowMetadata []byte + WindowOrigin string + WindowTimeFrom pgtype.Timestamp + WindowTimeTo pgtype.Timestamp + WindowTypeName string + WindowTypeVersion string + type ReadWindowTypesByNameParams struct + Name string + Version string + type RegisterMetadataParams struct + MetadataArray []float64 + MetadataJson []byte + MetadataKey string + MetadataValue pgtype.Float8 + WindowTypeID int64 + WindowsID int64 + type RegisterWindowParams struct + 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 + Error []byte + ID int64 + ResultArray []float64 + ResultJson []byte + ResultValue pgtype.Float8 + State AlgorithmState + 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 UpdateResultStateParams struct + ResultID int64 + State AlgorithmState + type UpdateWindowStateParams struct + State WindowState + WindowID int64 + type Window struct + Created pgtype.Timestamp + ID int64 + Origin string + State WindowState + TimeFrom pgtype.Timestamp + TimeTo pgtype.Timestamp + WindowTypeID int64 + type WindowState string + const WindowStateFAILED + const WindowStatePENDING + const WindowStatePROCESSING + const WindowStatePROCESSINGFINISHED + func (e *WindowState) Scan(src interface{}) error + 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.14.0-rc.8474fb1 Apr 28, 2026 v0.14.0-rc.4ad1d20 Apr 28, 2026
Go to main page