kubernetes_event

Documentation

Index

• Constants
• type Config
• type KubeEvent
  • func (k *KubeEvent) Category() api.Category
  • func (k *KubeEvent) Commit(events []api.Event)
  • func (k *KubeEvent) Config() interface{}
  • func (k *KubeEvent) Init(context api.Context) error
  • func (k *KubeEvent) ProductLoop(productFunc api.ProductFunc)
  • func (k *KubeEvent) Start() error
  • func (k *KubeEvent) Stop()
  • func (k *KubeEvent) String() string
  • func (k *KubeEvent) Type() api.Type

Constants

const Type = "kubeEvent"

Types

type Config

type Config struct {
	KubeConfig               string        `yaml:"kubeconfig,omitempty"`
	Master                   string        `yaml:"master,omitempty"`
	BufferSize               int           `yaml:"bufferSize,omitempty" default:"1000" validate:"gte=1"`
	LeaderElectionNamespace  string        `yaml:"electionNamespace,omitempty" default:"kube-system"`
	LeaderElectionKey        string        `yaml:"electionKey,omitempty" default:"loggie-leader-election-key"`
	LatestEventsEnabled      bool          `yaml:"watchLatestEvents,omitempty"`
	LatestEventsPreviousTime time.Duration `yaml:"latestEventsPreviousTime,omitempty" default:"30s"`
	BlackListNamespaces      []string      `yaml:"blackListNamespaces,omitempty"`
}

type KubeEvent

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

func (*KubeEvent) Category

func (k *KubeEvent) Category() api.Category

func (*KubeEvent) Commit

func (k *KubeEvent) Commit(events []api.Event)

func (*KubeEvent) Config

func (k *KubeEvent) Config() interface{}

func (*KubeEvent) Init

func (k *KubeEvent) Init(context api.Context) error

func (*KubeEvent) ProductLoop

func (k *KubeEvent) ProductLoop(productFunc api.ProductFunc)

func (*KubeEvent) Start

func (k *KubeEvent) Start() error

func (*KubeEvent) Stop

func (k *KubeEvent) Stop()

func (*KubeEvent) String

func (k *KubeEvent) String() string

func (*KubeEvent) Type

func (k *KubeEvent) Type() api.Type