events

Documentation

Index

• type EventIdentifier
• type Eventer
  • func InitEvents(client *client.Client, kube *kuber.Kube, skipNamespaces []string, ...) *Eventer
  • func NewEventer(client *client.Client, kube *kuber.Kube, skipNamespaces []string, ...) *Eventer
  • func (eventer *Eventer) ChangeStatus(entity string, id uuid.UUID, status watcher.Status, ...)
  • func (eventer *Eventer) GetAccountID(resource proc.Identifiable) (uuid.UUID, error)
  • func (eventer *Eventer) GetApplicationDesiredServices(id uuid.UUID) ([]uuid.UUID, error)
  • func (eventer *Eventer) GetApplicationID(resource proc.Identifiable) (uuid.UUID, error)
  • func (eventer *Eventer) GetContainerID(pod proc.Identifiable, containerName string) (uuid.UUID, error)
  • func (eventer *Eventer) GetID(resource proc.Identifiable) (string, error)
  • func (eventer *Eventer) GetServiceID(resource proc.Identifiable) (uuid.UUID, error)
  • func (eventer *Eventer) IsIgnored(resource proc.Identifiable) bool
  • func (eventer *Eventer) Start()
  • func (eventer *Eventer) WriteEvent(event *watcher.Event) error
  • func (eventer *Eventer) WriteEvents(events []*watcher.Event) error

Types

type EventIdentifier

type EventIdentifier struct {
	Entity   string
	EntityID string
	Kind     string
}

EventIdentifier entity identifier for events

type Eventer

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

Eventer event processor

func InitEvents

func InitEvents(
	client *client.Client,
	kube *kuber.Kube,
	skipNamespaces []string,
	scanner *scanner.Scanner,
	args map[string]interface{},
) *Eventer

InitEvents creates a new eventer then starts it

func NewEventer

func NewEventer(
	client *client.Client,
	kube *kuber.Kube,
	skipNamespaces []string,
	scanner *scanner.Scanner,
	bufferFlushInterval time.Duration,
	bufferSize int,
) *Eventer

NewEventer creates a new eventer

func (*Eventer) ChangeStatus

func (eventer *Eventer) ChangeStatus(
	entity string,
	id uuid.UUID,
	status watcher.Status,
	source *watcher.ContainerStatusSource,
)

ChangeStatus change status for an entity

func (*Eventer) GetAccountID

func (eventer *Eventer) GetAccountID(
	resource proc.Identifiable,
) (uuid.UUID, error)

GetAccountID returns resource account id

func (*Eventer) GetApplicationDesiredServices

func (eventer *Eventer) GetApplicationDesiredServices(
	id uuid.UUID,
) ([]uuid.UUID, error)

GetApplicationDesiredServices returns desired services of an application

func (*Eventer) GetApplicationID

func (eventer *Eventer) GetApplicationID(
	resource proc.Identifiable,
) (uuid.UUID, error)

GetApplicationID returns resource application id

func (*Eventer) GetContainerID

func (eventer *Eventer) GetContainerID(
	pod proc.Identifiable,
	containerName string,
) (uuid.UUID, error)

GetContainerID returns resource container id

func (*Eventer) GetID

func (eventer *Eventer) GetID(resource proc.Identifiable) (string, error)

GetID returns resource id

func (*Eventer) GetServiceID

func (eventer *Eventer) GetServiceID(
	resource proc.Identifiable,
) (uuid.UUID, error)

GetServiceID returns resource service id

func (*Eventer) IsIgnored

func (eventer *Eventer) IsIgnored(
	resource proc.Identifiable,
) bool

IsIgnored detects if it should be ignored It looks if the resource belongs to an ignored namespace

func (*Eventer) Start

func (eventer *Eventer) Start()

Start starts the eventer

func (*Eventer) WriteEvent

func (eventer *Eventer) WriteEvent(event *watcher.Event) error

WriteEvent writes an event

func (*Eventer) WriteEvents

func (eventer *Eventer) WriteEvents(events []*watcher.Event) error

WriteEvents writes batch of events