k8swatch

Documentation

Index

• Constants
• func DispatchServiceChange(st store.RStore, service *v1.Service, mn model.ManifestName, ip k8s.NodeIP) error
• func ShouldLogEvent(e *v1.Event) bool
• type EventWatchManager
  • func NewEventWatchManager(clients cluster.ClientProvider, cfgNS k8s.Namespace) *EventWatchManager
  • func (m *EventWatchManager) OnChange(ctx context.Context, st store.RStore, summary store.ChangeSummary) error
• type ServiceChangeAction
  • func NewServiceChangeAction(service *v1.Service, mn model.ManifestName, url *url.URL) ServiceChangeAction
  • func (ServiceChangeAction) Action()
• type ServiceWatcher
  • func NewServiceWatcher(clients cluster.ClientProvider, cfgNS k8s.Namespace) *ServiceWatcher
  • func (w *ServiceWatcher) OnChange(ctx context.Context, st store.RStore, summary store.ChangeSummary) error

Constants

const ImagePulledReason = "Pulled"

const ImagePullingReason = "Pulling"

Functions

func DispatchServiceChange

func DispatchServiceChange(st store.RStore, service *v1.Service, mn model.ManifestName, ip k8s.NodeIP) error

func ShouldLogEvent

func ShouldLogEvent(e *v1.Event) bool

Types

type EventWatchManager

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

TODO(nick): Right now, the EventWatchManager, PodWatcher, and ServiceWatcher all look very similar, with a few subtle differences (particularly in how we decide whether two objects are related, and how we index those relationships).

We're probably missing some abstractions here.

TODO(nick): We should also add garbage collection and/or handle Delete events from the kubernetes informer properly.

func NewEventWatchManager

func NewEventWatchManager(clients cluster.ClientProvider, cfgNS k8s.Namespace) *EventWatchManager

func (*EventWatchManager) OnChange

func (m *EventWatchManager) OnChange(ctx context.Context, st store.RStore, summary store.ChangeSummary) error

type ServiceChangeAction

type ServiceChangeAction struct {
	Service      *v1.Service
	ManifestName model.ManifestName
	URL          *url.URL
}

func NewServiceChangeAction

func NewServiceChangeAction(service *v1.Service, mn model.ManifestName, url *url.URL) ServiceChangeAction

func (ServiceChangeAction) Action

func (ServiceChangeAction) Action()

type ServiceWatcher

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

func NewServiceWatcher

func NewServiceWatcher(clients cluster.ClientProvider, cfgNS k8s.Namespace) *ServiceWatcher

func (*ServiceWatcher) OnChange

func (w *ServiceWatcher) OnChange(ctx context.Context, st store.RStore, summary store.ChangeSummary) error