k8swatch

package
v0.13.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 14, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ContainerStatusToRuntimeState added in v0.13.1

func ContainerStatusToRuntimeState(status v1.ContainerStatus) model.RuntimeStatus

func DispatchServiceChange

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

func PodStatusErrorMessages

func PodStatusErrorMessages(pod v1.Pod) []string

Pull out interesting error messages from the pod status

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) *EventWatchManager

func (*EventWatchManager) OnChange

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

type PodChangeAction

type PodChangeAction struct {
	Pod          *v1.Pod
	ManifestName model.ManifestName

	// The UID that we matched against to associate this pod with Tilt.
	// Might be the Pod UID itself, or the UID of an ancestor.
	MatchedAncestorUID types.UID
}

func NewPodChangeAction

func NewPodChangeAction(pod *v1.Pod, mn model.ManifestName, matchedAncestorUID types.UID) PodChangeAction

func (PodChangeAction) Action

func (PodChangeAction) Action()

type PodDeleteAction added in v0.12.0

type PodDeleteAction struct {
	PodID     k8s.PodID
	Namespace k8s.Namespace
}

func NewPodDeleteAction added in v0.12.0

func NewPodDeleteAction(podID k8s.PodID, namespace k8s.Namespace) PodDeleteAction

func (PodDeleteAction) Action added in v0.12.0

func (PodDeleteAction) Action()

type PodWatch

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

func (PodWatch) Equal

func (pw PodWatch) Equal(other PodWatch) bool

type PodWatcher

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

func NewPodWatcher

func NewPodWatcher(kCli k8s.Client, ownerFetcher k8s.OwnerFetcher) *PodWatcher

func (*PodWatcher) OnChange

func (w *PodWatcher) OnChange(ctx context.Context, st store.RStore)

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) *ServiceWatcher

func (*ServiceWatcher) OnChange

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL