k8s

Apr 22, 2019

Changes in this version

+ var NoFilter = func(v reflect.Value) bool

Apr 8, 2019

Changes in this version

+ const ManifestNameLabel

+ const TiltDeployIDLabel

+ const TiltRunIDLabel

+ var TiltRunID = uuid.New().String()

+ func ProvideClientConfig() clientcmd.ClientConfig

+ func ProvideClientSet(cfg *rest.Config) (*kubernetes.Clientset, error)

+ func ProvideContainerRuntime(ctx context.Context, kCli Client) container.Runtime

+ func ProvideKubeConfig(clientLoader clientcmd.ClientConfig) (*api.Config, error)

+ func ProvideKubectlRunner(kubeContext KubeContext) kubectlRunner

+ func ProvideServerVersion(clientSet *kubernetes.Clientset) (*version.Info, error)

+ func TiltDeployLabel(dID model.DeployID) model.LabelPair

+ func TiltRunLabel() model.LabelPair

+ func TiltRunSelector() labels.Selector

type Client

+ ContainerRuntime func(ctx context.Context) container.Runtime

+ Exec func(ctx context.Context, podID PodID, cName container.Name, n Namespace, ...) error

type Env

+ const EnvKIND

+ func EnvFromConfig(config *api.Config) Env

+ func ProvideEnv(kubeConfig *api.Config) Env

type FakeK8sClient

+ PodLogsByPodAndContainer map[PodAndCName]BufferCloser

+ Runtime container.Runtime

+ func (c *FakeK8sClient) ContainerRuntime(ctx context.Context) container.Runtime

+ func (c *FakeK8sClient) Exec(ctx context.Context, podID PodID, cName container.Name, n Namespace, ...) error

+ func (c *FakeK8sClient) SetLogsForPodContainer(pID PodID, cName container.Name, logs string)

+ type JSONPath struct

+ func NewJSONPath(s string) (JSONPath, error)

+ func (jp JSONPath) Execute(obj interface{}) (string, error)

+ func (jp JSONPath) String() string

type K8sClient

+ func (c K8sClient) ContainerRuntime(ctx context.Context) container.Runtime

+ func (k K8sClient) Exec(ctx context.Context, podID PodID, cName container.Name, n Namespace, ...) error

type K8sEntity

+ func FilterByHasPodTemplateSpec(entities []K8sEntity) (passing, rest []K8sEntity, err error)

+ func FilterByMatchesPodTemplateSpec(withPodSpec K8sEntity, entities []K8sEntity) (passing, rest []K8sEntity, err error)

+ func FilterByMetadataLabels(entities []K8sEntity, labels map[string]string) (passing, rest []K8sEntity, err error)

+ func FilterBySelectorMatchesLabels(entities []K8sEntity, labels map[string]string) (passing, rest []K8sEntity, err error)

+ func OverwriteLabels(entity K8sEntity, labels []model.LabelPair) (K8sEntity, error)

+ func (e K8sEntity) HasKind(kind string) bool

+ func (e K8sEntity) HasName(name string) bool

+ func (e K8sEntity) HasNamespace(ns string) bool

+ func (e K8sEntity) MatchesMetadataLabels(labels map[string]string) (bool, error)

+ func (e K8sEntity) ResourceName() string

+ func (e K8sEntity) SelectorMatchesLabels(labels map[string]string) bool

type KubeContext

+ func ProvideKubeContext(config *api.Config) (KubeContext, error)

type Namespace

+ func ProvideConfigNamespace(clientLoader clientcmd.ClientConfig) Namespace

+ type PodAndCName struct

+ CName container.Name

+ PID PodID

Feb 5, 2019

Changes in this version

+ func SelectorEqual(a, b labels.Selector) bool

type Client

+ func ProvideK8sClient(ctx context.Context, envOrErr EnvOrError) (Client, error)

type Env

+ func ProideEnv(envOrErr EnvOrError) Env

+ type EnvOrError struct

+ Env Env

+ Err error

+ func ProvideEnvOrError(ctx context.Context) EnvOrError

type FakeK8sClient

+ func (c *FakeK8sClient) EmitPod(ls labels.Selector, p *v1.Pod)

+ func (c *FakeK8sClient) WatchedSelectors() []labels.Selector

Jan 31, 2019

Changes in this version

+ const EnvNone

+ const KubeContextNone

+ func NewK8sOnlyManifest(name model.ManifestName, entities []K8sEntity) (model.Manifest, error)

+ func NewK8sOnlyManifestForTesting(name model.ManifestName, yaml string) model.Manifest

+ func NewTarget(name model.TargetName, entities []K8sEntity, portForwards []model.PortForward) (model.K8sTarget, error)

+ type KubeContext string

+ func DetectKubeContext(ctx context.Context) KubeContext

Jan 17, 2019

Changes in this version

+ const EnvMicroK8s

Jan 7, 2019

Changes in this version

type K8sEntity

+ func (e K8sEntity) FindImages() ([]reference.Named, error)

Dec 3, 2018

Changes in this version

+ func FindImageNamedTaggedMatching(pod v1.PodSpec, ref reference.Named) (reference.NamedTagged, error)

+ func FindImageRefMatching(pod v1.PodSpec, ref reference.Named) (reference.Named, error)

type Client

+ ConnectedToCluster func(ctx context.Context) error

type FakeK8sClient

+ UpsertError error

+ func (c *FakeK8sClient) ConnectedToCluster(ctx context.Context) error

+ func (c *FakeK8sClient) SetLogs(logs string)

type K8sClient

+ func (k K8sClient) ConnectedToCluster(ctx context.Context) error

Nov 5, 2018

Changes in this version

+ func ExtractPodTemplateSpec(obj interface{}) ([]*v1.PodTemplateSpec, error)

type K8sEntity

+ func Filter(entities []K8sEntity, test func(e K8sEntity) (bool, error)) (passing, rest []K8sEntity, err error)

+ func FilterByImage(entities []K8sEntity, img reference.Named) (passing, rest []K8sEntity, err error)

+ func FilterByLabels(entities []K8sEntity, labels map[string]string) (passing, rest []K8sEntity, err error)

+ func (e K8sEntity) HasImage(image reference.Named) (bool, error)

+ func (e K8sEntity) MatchesLabels(labels map[string]string) bool

+ type NodeIP string

+ func DetectNodeIP(ctx context.Context, env Env) (NodeIP, error)

Oct 24, 2018

Changes in this version

+ const ContainerIDPrefix

+ const DefaultNamespace

+ const EnvDockerDesktop

+ const EnvGKE

+ const EnvMinikube

+ const EnvUnknown

+ const MagicTestContainerID

+ func ContainerMatching(pod *v1.Pod, ref reference.Named) (v1.ContainerStatus, error)

+ func ContainerSpecOf(pod *v1.Pod, status v1.ContainerStatus) v1.Container

+ func ExtractPods(obj interface{}) ([]*v1.PodSpec, error)

+ func FakePodSpec(image reference.NamedTagged) v1.PodSpec

+ func FakePodStatus(image reference.NamedTagged, phase string) v1.PodStatus

+ func IsContainerExited(pod v1.PodStatus, container v1.ContainerStatus) bool

+ func IsUnschedulable(pod v1.PodStatus) (bool, string)

+ func MustParseNamed(s string) reference.Named

+ func MustParseNamedTagged(s string) reference.NamedTagged

+ func OpenService(ctx context.Context, client Client, lbSpec LoadBalancerSpec) error

+ func ParseNamedTagged(s string) (reference.NamedTagged, error)

+ func PodContainsRef(pod *v1.PodSpec, ref reference.Named) (bool, error)

+ func ProvideCoreInterface(cfg *rest.Config) (apiv1.CoreV1Interface, error)

+ func ProvideRESTClient(cfg *rest.Config) (apiv1.CoreV1Interface, error)

+ func ProvideRESTConfig() (*rest.Config, error)

+ func SerializeYAML(decoded []K8sEntity) (string, error)

+ func ServiceURL(service *v1.Service) (*url.URL, error)

+ func WaitForContainerReady(ctx context.Context, client Client, pod *v1.Pod, ref reference.Named) (v1.ContainerStatus, error)

+ type BufferCloser struct

+ func (b BufferCloser) Close() error

+ type Client interface

+ ContainerLogs func(ctx context.Context, podID PodID, cName ContainerName, n Namespace) (io.ReadCloser, error)

+ Delete func(ctx context.Context, entities []K8sEntity) error

+ FindAppByNode func(ctx context.Context, nodeID NodeID, appName string, ...) (PodID, error)

+ ForwardPort func(ctx context.Context, namespace Namespace, podID PodID, ...) (localPort int, closer func(), err error)

+ GetNodeForPod func(ctx context.Context, podID PodID) (NodeID, error)

+ PodByID func(ctx context.Context, podID PodID, n Namespace) (*v1.Pod, error)

+ PodsWithImage func(ctx context.Context, image reference.NamedTagged, n Namespace, ...) ([]v1.Pod, error)

+ PollForPodsWithImage func(ctx context.Context, image reference.NamedTagged, n Namespace, ...) ([]v1.Pod, error)

+ ResolveLoadBalancer func(ctx context.Context, lb LoadBalancerSpec) (LoadBalancer, error)

+ Upsert func(ctx context.Context, entities []K8sEntity) error

+ WatchPod func(ctx context.Context, pod *v1.Pod) (watch.Interface, error)

+ WatchPods func(ctx context.Context, lps []LabelPair) (<-chan *v1.Pod, error)

+ WatchServices func(ctx context.Context, lps []LabelPair) (<-chan *v1.Service, error)

+ type ContainerID string

+ func ContainerIDFromContainerStatus(status v1.ContainerStatus) (ContainerID, error)

+ func (cID ContainerID) Empty() bool

+ func (cID ContainerID) ShortStr() string

+ func (cID ContainerID) String() string

+ type ContainerName string

+ func ContainerNameFromContainerStatus(status v1.ContainerStatus) ContainerName

+ func (n ContainerName) String() string

+ type Env string

+ func DetectEnv() (Env, error)

+ func EnvFromString(s string) Env

+ func (e Env) IsLocalCluster() bool

+ type FakeK8sClient struct

+ ContainerLogsError error

+ DeletedYaml string

+ LastForwardPortPodID PodID

+ LastForwardPortRemotePort int

+ LastPodQueryImage reference.NamedTagged

+ LastPodQueryNamespace Namespace

+ Lb LoadBalancerSpec

+ PodLogs string

+ PodsWithImageError error

+ PodsWithImageResp PodID

+ PollForPodsWithImageDelay time.Duration

+ Yaml string

+ func NewFakeK8sClient() *FakeK8sClient

+ func (c *FakeK8sClient) ContainerLogs(ctx context.Context, pID PodID, cName ContainerName, n Namespace) (io.ReadCloser, error)

+ func (c *FakeK8sClient) Delete(ctx context.Context, entities []K8sEntity) error

+ func (c *FakeK8sClient) FindAppByNode(ctx context.Context, nodeID NodeID, appName string, ...) (PodID, error)

+ func (c *FakeK8sClient) ForwardPort(ctx context.Context, namespace Namespace, podID PodID, ...) (int, func(), error)

+ func (c *FakeK8sClient) GetNodeForPod(ctx context.Context, podID PodID) (NodeID, error)

+ func (c *FakeK8sClient) PodByID(ctx context.Context, pID PodID, n Namespace) (*v1.Pod, error)

+ func (c *FakeK8sClient) PodsWithImage(ctx context.Context, image reference.NamedTagged, n Namespace, ...) ([]v1.Pod, error)

+ func (c *FakeK8sClient) PollForPodsWithImage(ctx context.Context, image reference.NamedTagged, n Namespace, ...) ([]v1.Pod, error)

+ func (c *FakeK8sClient) ResolveLoadBalancer(ctx context.Context, lb LoadBalancerSpec) (LoadBalancer, error)

+ func (c *FakeK8sClient) SetPodsWithImageResp(pID PodID)

+ func (c *FakeK8sClient) SetPollForPodsWithImageDelay(dur time.Duration)

+ func (c *FakeK8sClient) Upsert(ctx context.Context, entities []K8sEntity) error

+ func (c *FakeK8sClient) WatchPod(ctx context.Context, pod *v1.Pod) (watch.Interface, error)

+ func (c *FakeK8sClient) WatchPods(ctx context.Context, lps []LabelPair) (<-chan *v1.Pod, error)

+ func (c *FakeK8sClient) WatchServices(ctx context.Context, lps []LabelPair) (<-chan *v1.Service, error)

+ type FindAppByNodeOptions struct

+ Namespace string

+ Owner string

+ type K8sClient struct

+ func NewK8sClient(ctx context.Context, env Env, core apiv1.CoreV1Interface, ...) K8sClient

+ func (k K8sClient) ContainerLogs(ctx context.Context, pID PodID, cName ContainerName, n Namespace) (io.ReadCloser, error)

+ func (k K8sClient) Delete(ctx context.Context, entities []K8sEntity) error

+ func (k K8sClient) FindAppByNode(ctx context.Context, nodeID NodeID, appName string, ...) (PodID, error)

+ func (k K8sClient) ForwardPort(ctx context.Context, namespace Namespace, podID PodID, ...) (localPort int, closer func(), err error)

+ func (k K8sClient) GetNodeForPod(ctx context.Context, podID PodID) (NodeID, error)

+ func (k K8sClient) PodByID(ctx context.Context, pID PodID, n Namespace) (*v1.Pod, error)

+ func (k K8sClient) PodsWithImage(ctx context.Context, image reference.NamedTagged, n Namespace, ...) ([]v1.Pod, error)

+ func (k K8sClient) PollForPodsWithImage(ctx context.Context, image reference.NamedTagged, n Namespace, ...) ([]v1.Pod, error)

+ func (k K8sClient) ResolveLoadBalancer(ctx context.Context, lb LoadBalancerSpec) (LoadBalancer, error)

+ func (k K8sClient) Upsert(ctx context.Context, entities []K8sEntity) error

+ func (k K8sClient) WatchPod(ctx context.Context, pod *v1.Pod) (watch.Interface, error)

+ func (kCli K8sClient) WatchPods(ctx context.Context, lps []LabelPair) (<-chan *v1.Pod, error)

+ func (kCli K8sClient) WatchServices(ctx context.Context, lps []LabelPair) (<-chan *v1.Service, error)

+ type K8sEntity struct

+ Kind *schema.GroupVersionKind

+ Obj runtime.Object

+ func ImmutableEntities(entities []K8sEntity) []K8sEntity

+ func InjectImageDigest(entity K8sEntity, injectRef reference.Named, policy v1.PullPolicy) (K8sEntity, bool, error)

+ func InjectImagePullPolicy(entity K8sEntity, policy v1.PullPolicy) (K8sEntity, error)

+ func InjectLabels(entity K8sEntity, labels []LabelPair) (K8sEntity, error)

+ func MutableEntities(entities []K8sEntity) []K8sEntity

+ func ParseYAML(k8sYaml io.Reader) ([]K8sEntity, error)

+ func ParseYAMLFromString(yaml string) ([]K8sEntity, error)

+ func (e K8sEntity) DeepCopy() K8sEntity

+ func (e K8sEntity) ImmutableOnceCreated() bool

+ func (e K8sEntity) Meta() metav1.ObjectMeta

+ func (e K8sEntity) Name() string

+ func (e K8sEntity) Namespace() Namespace

+ type LabelPair struct

+ Key string

+ Value string

+ type LoadBalancer struct

+ Spec LoadBalancerSpec

+ URL *url.URL

+ type LoadBalancerSpec struct

+ Name string

+ Namespace Namespace

+ Ports []int32

+ func ToLoadBalancerSpec(entity K8sEntity) (LoadBalancerSpec, bool)

+ func ToLoadBalancerSpecs(entities []K8sEntity) []LoadBalancerSpec

+ type MultipleAppsFoundError struct

+ func (m MultipleAppsFoundError) Error() string

+ type Namespace string

+ func NamespaceFromPod(pod *v1.Pod) Namespace

+ func (n Namespace) String() string

+ type NodeID string

+ func NodeIDFromPod(pod *v1.Pod) NodeID

+ func (nID NodeID) String() string

+ type PodID string

+ func PodIDFromPod(pod *v1.Pod) PodID

+ func (pID PodID) Empty() bool

+ func (pID PodID) String() string

+ type PortForwarder func(ctx context.Context, restConfig *rest.Config, core apiv1.CoreV1Interface, ...) (closer func(), err error)

+ func ProvidePortForwarder() PortForwarder

+ type ServiceName string