automation

Oct 26, 2023

Changes in this version

+ const ErrBadConfig

+ func AttrDataFrame(data views.DataFrame) slog.Attr

+ func AttrError(err error) slog.Attr

+ type ActionFunc func(ctx context.Context, cfg *Config, result *EvaluateResult) bool

+ func ActionAnnotate(key, value string) ActionFunc

+ func ActionRoutine(r Routine) ActionFunc

+ func ActionSeriesContains(series string, value float64) ActionFunc

+ type Config struct

+ func NewConfig(client *clarify.Client) *Config

+ func (cfg *Config) AppName() string

+ func (cfg *Config) DryRun() bool

+ func (cfg *Config) EarlyOut() bool

+ func (cfg *Config) Logger() *slog.Logger

+ func (cfg *Config) RoutinePath() string

+ func (cfg Config) Client() *clarify.Client

+ func (cfg Config) WithAppName(name string) *Config

+ func (cfg Config) WithDryRun(dryRun bool) *Config

+ func (cfg Config) WithEarlyOut(value bool) *Config

+ func (cfg Config) WithLogger(l *slog.Logger) *Config

+ func (cfg Config) WithSubRoutineName(name string) *Config

+ type EvaluateActions struct

+ Actions []ActionFunc

+ Evaluation Evaluation

+ RollupBucket fields.CalendarDuration

+ TimeFunc func(time.Time) (gte, lt time.Time)

+ func (e EvaluateActions) Do(ctx context.Context, cfg *Config) error

+ type EvaluateResult struct

+ Annotations fields.Annotations

+ Data views.DataFrame

+ type Evaluation struct

+ Calculations []fields.Calculation

+ Items []fields.ItemAggregation

+ SeriesIn []string

+ type Routine interface

+ Do func(context.Context, *Config) error

+ type RoutineFunc func(context.Context, *Config) error

+ func LogDebug(msg string, attrs ...slog.Attr) RoutineFunc

+ func LogError(msg string, attrs ...slog.Attr) RoutineFunc

+ func LogInfo(msg string, attrs ...slog.Attr) RoutineFunc

+ func LogWarn(msg string, attrs ...slog.Attr) RoutineFunc

+ func (f RoutineFunc) Do(ctx context.Context, params *Config) error

+ type Routines map[string]Routine

+ func (routines Routines) Do(ctx context.Context, cfg *Config) error

+ func (routines Routines) SubRoutines(patterns ...string) Routines

Oct 12, 2022

Changes in this version

+ const AnnotationPrefix

+ const AnnotationPublisherName

+ const AnnotationPublisherSignalAttributes

+ const AnnotationPublisherSignalID

+ const AnnotationPublisherTransformVersion

+ type LogOptions struct

+ Out io.Writer

+ Verbose bool

+ func (opts LogOptions) EncodeJSON(v any)

+ func (opts LogOptions) Printf(format string, a ...any)

+ type PublishOptions struct

+ DryRun bool

+ Publisher string

+ type PublishSignals struct

+ Integrations []string

+ SignalsFilter query.FilterType

+ TransformVersion string

+ Transforms []func(item *views.ItemSave)

+ func (p PublishSignals) Do(ctx context.Context, c *clarify.Client, opts PublishOptions) error