observe

type Input ¶ added in v0.13.14

type Input struct {
	Dataset *string ` json:"dataset,omitempty"`
}

Input references an existing data source

type Poller ¶ added in v0.13.14

type Poller struct {
	// Interval configures the time interval before reattempting to invoke function
	Interval *time.Duration
	// Timeout specifies the upperbound we will attempt to get a result which meets exit condition
	Timeout *time.Duration
}

Poller runs function periodically until exit condition is met

func (p *Poller) Run(ctx context.Context, fn func(context.Context) error, exitCond func() bool) error

type Query ¶ added in v0.13.14

type Query struct {
	Inputs   map[string]*Input `json:"inputs"`
	Stages   []*Stage          `json:"stages"`
	StageIds []string          `json:"stage_ids"`
}

type Stage ¶ added in v0.13.14

type Stage struct {
	Alias       *string `json:"alias,omitempty"`
	Input       *string `json:"input,omitempty"`
	Pipeline    string  `json:"pipeline"`
	OutputStage bool    `json:"outputStage"`
}

Stage applies a pipeline to an input If no input is provided, stage will follow on from previous stage An alias must be provided for callers to be able to reference this stage in OPAL Internally, the alias does not map to the stageID - it is the input name we use when refering to this stage