k8swatch

Documentation

Index

• Constants
• func ContainerStatusToRuntimeState(status v1.ContainerStatus) model.RuntimeStatus
• func DispatchServiceChange(st store.RStore, service *v1.Service, mn model.ManifestName, ip k8s.NodeIP) error
• func PodStatusErrorMessages(pod v1.Pod) []string
• func PodStatusToString(pod v1.Pod) string
• func ShouldLogEvent(e *v1.Event) bool
• type EventWatchManager
  • func NewEventWatchManager(kClient k8s.Client, ownerFetcher k8s.OwnerFetcher, cfgNS k8s.Namespace) *EventWatchManager
  • func (m *EventWatchManager) OnChange(ctx context.Context, st store.RStore)
• type ExtraSelector
• type PodChangeAction
  • func NewPodChangeAction(pod *v1.Pod, mn model.ManifestName, matchedAncestorUID types.UID) PodChangeAction
  • func (PodChangeAction) Action()
• type PodDeleteAction
  • func NewPodDeleteAction(podID k8s.PodID, namespace k8s.Namespace) PodDeleteAction
  • func (PodDeleteAction) Action()
• type PodWatcher
  • func NewPodWatcher(kCli k8s.Client, ownerFetcher k8s.OwnerFetcher, cfgNS k8s.Namespace) *PodWatcher
  • func (w *PodWatcher) OnChange(ctx context.Context, st store.RStore)
• 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)

Constants

const ImagePulledReason = "Pulled"

const ImagePullingReason = "Pulling"

Functions

func ContainerStatusToRuntimeState

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

func PodStatusToString

func PodStatusToString(pod v1.Pod) string

copied from https://github.com/kubernetes/kubernetes/blob/aedeccda9562b9effe026bb02c8d3c539fc7bb77/pkg/kubectl/resource_printer.go#L692-L764 to match the status column of `kubectl get pods`

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

func (*EventWatchManager) OnChange

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

type ExtraSelector

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

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

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

func NewPodDeleteAction

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

func (PodDeleteAction) Action

func (PodDeleteAction) Action()

type PodWatcher

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

func NewPodWatcher

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

func (*ServiceWatcher) OnChange

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