act

type Action struct {
	Name     string         `json:"name"`
	Metadata map[string]any `json:"metadata"`
	Sync     bool           `json:"sync"`
	Terminal bool           `json:"terminal"`
	Timeout  int            `json:"timeout"`
	Run      ActionFunc     `json:"-"`
}

type ActionFunc func(data map[string]any, params ...Parameter) (any, error)

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

type Hook struct {
	Name     string         `json:"name"`
	Priority uint           `json:"priority"`
	Params   map[string]any `json:"params"`
	Result   map[string]any `json:"result"`
}

type IConsumer interface {
	Subscribe(ctx context.Context, handler MessageHandlerFn) error
}

type IPolicy interface {
	MustCompile(opts ...expr.Option) error
	Eval(ctx context.Context, input Input) (any, error)
}

type Input struct {
	Name   string         `json:"name"`
	Policy map[string]any `json:"policy"`
	Signal map[string]any `json:"signal"`
	Hook   Hook           `json:"hook"`
	Sync   bool           `json:"sync"`
}

type MessageHandlerFn func(ctx context.Context, payload []byte) error

type Output struct {
	MatchedPolicy string         `json:"matchedPolicy"`
	Metadata      map[string]any `json:"metadata"`
	Verdict       any            `json:"verdict"`
	Terminal      bool           `json:"terminal"`
	Sync          bool           `json:"sync"`
}

type Parameter struct {
	Key   string
	Value any
}

type Policy struct {
	Name     string         `json:"name"`
	Policy   string         `json:"policy"`
	Metadata map[string]any `json:"metadata"`
	// contains filtered or unexported fields
}

type Signal struct {
	Name     string         `json:"name"`
	Metadata map[string]any `json:"metadata"`
}