uik

type ActionError ¶

type ActionError struct {
	Index int
	Err   error
}

ActionError is an error that occurred while processing an action.

func (a *ActionError) Error() string

type CompiledAction ¶

type CompiledAction struct {
	gadb.UIKActionV1
	Params map[string]*vm.Program
}

CompiledAction is a compiled version of a UIKActionV1.

func NewCompiledAction(a gadb.UIKActionV1) (*CompiledAction, error)

func (a *CompiledAction) Run(vm *vm.VM, env any) (result gadb.UIKActionV1, err error)

type CompiledConfig ¶

type CompiledConfig struct {
	gadb.UIKConfigV1
	CompiledRules  []CompiledRule
	DefaultActions []CompiledAction
}

CompiledConfig is a compiled version of a UIKConfigV1.

func NewCompiledConfig(cfg gadb.UIKConfigV1) (*CompiledConfig, error)

func (c *CompiledConfig) Run(vm *vm.VM, env any) (actions []gadb.UIKActionV1, err error)

type CompiledRule ¶

type CompiledRule struct {
	gadb.UIKRuleV1
	Condition *vm.Program
	Actions   []CompiledAction
}

CompiledRule is a compiled version of a UIKRuleV1.

func NewCompiledRule(r gadb.UIKRuleV1) (*CompiledRule, error)

func (r *CompiledRule) Run(vm *vm.VM, env any) (actions []gadb.UIKActionV1, matched bool, err error)

type ConditionError ¶

type ConditionError struct {
	Err error
}

ConditionError is an error that occurred while processing a condition.

func (c *ConditionError) Error() string

type Handler ¶

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

func NewHandler(db TxAble, intStore *integrationkey.Store, aStore *alert.Store, r *river.Client[pgx.Tx]) *Handler

func (h *Handler) ServeHTTP(w http.ResponseWriter, req *http.Request)

type ParamError ¶

type ParamError struct {
	ParamID string
	Err     error
}

ParamError is an error that occurred while processing a param.

func (p *ParamError) Error() string

type RuleError ¶

type RuleError struct {
	Index int
	Name  string
	Err   error
}

RuleError is an error that occurred while processing a rule.

func (r *RuleError) Error() string

type TxAble ¶

type TxAble interface {
	gadb.DBTX
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
}