log

Documentation

Index

• type LogTrigger
  • func NewLogTrigger(sensor *v1alpha1.Sensor, trigger *v1alpha1.Trigger, logger *zap.SugaredLogger) (*LogTrigger, error)
  • func (t *LogTrigger) ApplyPolicy(context.Context, interface{}) error
  • func (t *LogTrigger) ApplyResourceParameters(_ map[string]*v1alpha1.Event, resource interface{}) (interface{}, error)
  • func (t *LogTrigger) Execute(ctx context.Context, events map[string]*v1alpha1.Event, resource interface{}) (interface{}, error)
  • func (t *LogTrigger) FetchResource(ctx context.Context) (interface{}, error)
  • func (t *LogTrigger) GetTriggerType() apicommon.TriggerType

Types

type LogTrigger

type LogTrigger struct {
	Sensor      *v1alpha1.Sensor
	Trigger     *v1alpha1.Trigger
	Logger      *zap.SugaredLogger
	LastLogTime time.Time
}

func NewLogTrigger

func NewLogTrigger(sensor *v1alpha1.Sensor, trigger *v1alpha1.Trigger, logger *zap.SugaredLogger) (*LogTrigger, error)

func (*LogTrigger) ApplyPolicy

func (t *LogTrigger) ApplyPolicy(context.Context, interface{}) error

func (*LogTrigger) ApplyResourceParameters

func (t *LogTrigger) ApplyResourceParameters(_ map[string]*v1alpha1.Event, resource interface{}) (interface{}, error)

func (*LogTrigger) Execute

func (t *LogTrigger) Execute(ctx context.Context, events map[string]*v1alpha1.Event, resource interface{}) (interface{}, error)

func (*LogTrigger) FetchResource

func (t *LogTrigger) FetchResource(ctx context.Context) (interface{}, error)

func (*LogTrigger) GetTriggerType

func (t *LogTrigger) GetTriggerType() apicommon.TriggerType

GetTriggerType returns the type of the trigger