k8swatch

Documentation

Index

• Constants
• func CheckForContainerCrash(state *store.EngineState, mt *store.ManifestTarget)
• func DispatchServiceChange(st store.RStore, service *v1.Service, mn model.ManifestName, ip k8s.NodeIP) error
• func HandleKubernetesDiscoveryUpdateStatusAction(ctx context.Context, state *store.EngineState, ...)
• func ShouldLogEvent(e *v1.Event) bool
• func UpdateK8sRuntimeState(ctx context.Context, state *store.EngineState, objMeta *metav1.ObjectMeta, ...)
• type EventWatchManager
  • func NewEventWatchManager(kClient k8s.Client, ownerFetcher k8s.OwnerFetcher, cfgNS k8s.Namespace) *EventWatchManager
  • func (m *EventWatchManager) OnChange(ctx context.Context, st store.RStore, _ store.ChangeSummary) error
• type KubernetesDiscoveryUpdateStatusAction
  • func NewKubernetesDiscoveryUpdateStatusAction(kd *v1alpha1.KubernetesDiscovery) KubernetesDiscoveryUpdateStatusAction
  • func (p KubernetesDiscoveryUpdateStatusAction) Action()
• type ServiceChangeAction
  • func NewServiceChangeAction(service *v1.Service, mn model.ManifestName, url *url.URL) ServiceChangeAction
  • func (ServiceChangeAction) Action()
• type ServiceWatcher
  • func NewServiceWatcher(kCli k8s.Client, ownerFetcher k8s.OwnerFetcher, cfgNS k8s.Namespace) *ServiceWatcher
  • func (w *ServiceWatcher) OnChange(ctx context.Context, st store.RStore, _ store.ChangeSummary) error

Constants

const ImagePulledReason = "Pulled"

const ImagePullingReason = "Pulling"

Functions

func CheckForContainerCrash

func CheckForContainerCrash(state *store.EngineState, mt *store.ManifestTarget)

func DispatchServiceChange

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

func HandleKubernetesDiscoveryUpdateStatusAction

func HandleKubernetesDiscoveryUpdateStatusAction(ctx context.Context, state *store.EngineState, a KubernetesDiscoveryUpdateStatusAction)

func ShouldLogEvent

func ShouldLogEvent(e *v1.Event) bool

func UpdateK8sRuntimeState

func UpdateK8sRuntimeState(ctx context.Context, state *store.EngineState, objMeta *metav1.ObjectMeta, status *v1alpha1.KubernetesDiscoveryStatus)

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(kClient k8s.Client, ownerFetcher k8s.OwnerFetcher, cfgNS k8s.Namespace) *EventWatchManager

func (*EventWatchManager) OnChange

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

type KubernetesDiscoveryUpdateStatusAction

type KubernetesDiscoveryUpdateStatusAction struct {
	ObjectMeta *metav1.ObjectMeta
	Status     *v1alpha1.KubernetesDiscoveryStatus
}

func NewKubernetesDiscoveryUpdateStatusAction

func NewKubernetesDiscoveryUpdateStatusAction(kd *v1alpha1.KubernetesDiscovery) KubernetesDiscoveryUpdateStatusAction

func (KubernetesDiscoveryUpdateStatusAction) Action

func (p KubernetesDiscoveryUpdateStatusAction) Action()

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(kCli k8s.Client, ownerFetcher k8s.OwnerFetcher, cfgNS k8s.Namespace) *ServiceWatcher

func (*ServiceWatcher) OnChange

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