filters

Documentation

Index

• Constants
• type NodeEventsChecker
  • func NewNodeEventsChecker(log logrus.FieldLogger) *NodeEventsChecker
  • func (f *NodeEventsChecker) Describe() string
  • func (f *NodeEventsChecker) Name() string
  • func (f *NodeEventsChecker) Run(_ context.Context, event *event.Event) error
• type ObjectAnnotationChecker
  • func NewObjectAnnotationChecker(log logrus.FieldLogger, dynamicCli dynamic.Interface, mapper meta.RESTMapper) *ObjectAnnotationChecker
  • func (f *ObjectAnnotationChecker) Describe() string
  • func (f *ObjectAnnotationChecker) Name() string
  • func (f *ObjectAnnotationChecker) Run(ctx context.Context, event *event.Event) error

Constants

const (
	// NodeNotReady EventReason when Node is NotReady
	NodeNotReady string = "NodeNotReady"
	// NodeReady EventReason when Node is Ready
	NodeReady string = "NodeReady"
)

const (
	// DisableAnnotation is the object disable annotation.
	DisableAnnotation string = "botkube.io/disable"
	// ChannelAnnotation is the multichannel support annotation.
	ChannelAnnotation string = "botkube.io/channel"
)

Types

type NodeEventsChecker

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

NodeEventsChecker checks job status and adds message in the events structure

func NewNodeEventsChecker

func NewNodeEventsChecker(log logrus.FieldLogger) *NodeEventsChecker

NewNodeEventsChecker creates a new NodeEventsChecker instance

func (*NodeEventsChecker) Describe

func (f *NodeEventsChecker) Describe() string

Describe describes the filter

func (*NodeEventsChecker) Name

func (f *NodeEventsChecker) Name() string

Name returns the filter's name

func (*NodeEventsChecker) Run

func (f *NodeEventsChecker) Run(_ context.Context, event *event.Event) error

Run filers and modifies event struct

type ObjectAnnotationChecker

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

ObjectAnnotationChecker forwards events to specific channels based on a special annotation if it is set on a given K8s resource.

func NewObjectAnnotationChecker

func NewObjectAnnotationChecker(log logrus.FieldLogger, dynamicCli dynamic.Interface, mapper meta.RESTMapper) *ObjectAnnotationChecker

NewObjectAnnotationChecker creates a new ObjectAnnotationChecker instance.

func (*ObjectAnnotationChecker) Describe

func (f *ObjectAnnotationChecker) Describe() string

Describe describes the filter.

func (*ObjectAnnotationChecker) Name

func (f *ObjectAnnotationChecker) Name() string

Name returns the filter's name.

func (*ObjectAnnotationChecker) Run

func (f *ObjectAnnotationChecker) Run(ctx context.Context, event *event.Event) error

Run filters and modifies event struct.