events

Documentation

Index

• type EventCollector
  • func NewEventCollector(ctx context.Context, endpoint string, opts ...EventCollectorOption) *EventCollector
  • func (c *EventCollector) Run(stopCh <-chan struct{}) error
• type EventCollectorOption
  • func WithMaxRetries(retries int) EventCollectorOption
• type EventCollectorOptions
• type EventOutput

Types

type EventCollector

type EventCollector struct {
	EventCollectorOptions
	// contains filtered or unexported fields
}

func NewEventCollector

func NewEventCollector(ctx context.Context, endpoint string, opts ...EventCollectorOption) *EventCollector

func (*EventCollector) Run

func (c *EventCollector) Run(stopCh <-chan struct{}) error

type EventCollectorOption

type EventCollectorOption func(*EventCollectorOptions)

func WithMaxRetries

func WithMaxRetries(retries int) EventCollectorOption

type EventCollectorOptions

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

type EventOutput

type EventOutput struct {
	*corev1.Event
	ClusterID string    `json:"cluster_id,omitempty"`
	LogType   string    `json:"log_type,omitempty"`
	PodName   string    `json:"pod_name,omitempty"`
	Time      time.Time `json:"time,omitempty"`
}