preprocessor

Documentation

Index

• type Event
• type EventMessage
• type EventPreprocessor
  • func New(logger logr.Logger, router EventRouter) *EventPreprocessor
  • func (processor *EventPreprocessor) ReceiveEvent(ctx context.Context, req *pb.EventRequest) (pb.ResponseType, error)
• type EventReceiver
• type EventRouter
• type EventType
• type RequestKey

Types

type Event

type Event struct {
	Type      EventType
	Timestamp time.Time
	Key       RequestKey
	Object    runtime.Object
}

type EventMessage

type EventMessage struct {
	Ctx context.Context
	Err chan error

	Event
}

type EventPreprocessor

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

EventPreprocessor identifies the EventType for incoming events and routes them to the EventRouter. In case of List events, it buffers constituting list pages and provides the router with consolidated list events

func New

func New(logger logr.Logger, router EventRouter) *EventPreprocessor

New instantiates a new EventPreprocessor which passes the event to a router object

func (*EventPreprocessor) ReceiveEvent

func (processor *EventPreprocessor) ReceiveEvent(ctx context.Context,
	req *pb.EventRequest) (pb.ResponseType, error)

ReceiveEvent receives pb.EventRequest and passes it to watch/list handler

type EventReceiver

type EventReceiver interface {
	ReceiveEvent(ctx context.Context, req *pb.EventRequest) (pb.ResponseType, error)
}

type EventRouter

type EventRouter interface {
	RouteEvent(key RequestKey) chan *EventMessage
}

type EventType

type EventType string

const (
	List     EventType = "LIST"
	Added    EventType = "ADDED"
	Modified EventType = "MODIFIED"
	Deleted  EventType = "DELETED"
)

type RequestKey

type RequestKey struct {
	ClusterName string
	Group       string
	Version     string
	Kind        string
	Namespace   string
	NFDeploy    string
}