kubernetes

Mar 3, 2023

Changes in this version

type Planner

+ func (r Planner) MakeServiceName(name string) (string, string)

Feb 8, 2023

Changes in this version

+ func WatchDeployable(ctx context.Context, actionName string, cli *k8s.Clientset, namespace string, ...) (V, error)

Feb 5, 2023

Changes in this version

+ type ServiceReadiness struct

+ Message string

+ Ready bool

+ func AreServicesReady(ctx context.Context, cli *kubernetes.Clientset, namespace string, ...) (ServiceReadiness, error)

Jan 31, 2023

Changes in this version

+ func ClusterIngress(cluster *Cluster) (kubedef.IngressClass, error)

Jan 30, 2023

Changes in this version

+ const DiscoveryStateKey

Jan 27, 2023

Changes in this version

type Cluster

+ func (r *Cluster) EnsureKeyedState(ctx context.Context, key, secondary string) (any, error)

Jan 15, 2023

Changes in this version

+ type BoundNamespace struct

Jan 10, 2023

Changes in this version

+ func IngressOwnedBy(allFragments []*fnschema.IngressFragment, srv fnschema.PackageName) []*fnschema.IngressFragment

type Cluster

+ IngressClass kubedef.IngressClass

+ Prepared client.Prepared

+ type NewClusterOpts struct

+ FetchSystemInfo FetchSystemInfoFunc

+ SupportedIngressClasses []string

Dec 16, 2022

Changes in this version

type Cluster

+ func (u *Cluster) Ingress() kubedef.IngressClass

type Planner

+ func (r Planner) Ingress() runtime.IngressClass

Dec 4, 2022

Changes in this version

type Cluster

+ func NewCluster(cli *client.Prepared, config cfg.Configuration, ...) *Cluster

+ type FetchSystemInfoFunc func(context.Context) (*kubedef.SystemInfo, error)

type Planner

+ Configuration cfg.Configuration

+ func (r Planner) ClusterNamespaceFor(parent runtime.Cluster, underlying *Cluster) *ClusterNamespace

+ func (r Planner) EnsureClusterNamespace(ctx context.Context) (runtime.ClusterNamespace, error)

Dec 2, 2022

Changes in this version

type ClusterNamespace

+ func NewClusterNamespace(env cfg.Context, parent runtime.Cluster, u *Cluster) *ClusterNamespace

Nov 25, 2022

Changes in this version

type Cluster

+ Configuration cfg.Configuration

+ func (u *Cluster) KubernetesCluster() *Cluster

type ClusterNamespace

+ func NewClusterNamespaceWithPlanner(env cfg.Context, parent runtime.Cluster, u *Cluster, planner runtime.Planner) *ClusterNamespace

+ type UnwrapCluster interface

+ KubernetesCluster func() *Cluster

Nov 23, 2022

Changes in this version

type Planner

+ func NewPlannerWithRegistry(env cfg.Context, registry registry.Manager, ...) Planner

+ func (r Planner) Registry() registry.Manager

Oct 26, 2022

Changes in this version

type ClusterNamespace

+ func (r *ClusterNamespace) WaitUntilReady(ctx context.Context, srv runtime.Deployable) error

Oct 24, 2022

Changes in this version

+ const PortForwardProtocolV1Name

+ const RestmapperStateKey

+ var DeployAsPodsInTests = true

+ var ObserveInitContainerLogs = false

+ var ProductionPlatforms = []string

+ var UseNodePlatformsForProduction = false

+ func DeleteAllRecursively(ctx context.Context, cli *kubernetes.Clientset, wait bool, progress io.Writer, ...) (bool, error)

+ func MakeNamespace(env *schema.Environment, ns string) *applycorev1.NamespaceApplyConfiguration

+ func ModuleNamespace(ws *schema.Workspace, env *schema.Environment) string

+ func PrepareProvisionWith(env *schema.Environment, ns string, systemInfo *kubedef.SystemInfo) (*rtypes.ProvisionProps, error)

+ func Register()

+ func RegisterOverrideClass(name string, p ProvideOverrideFunc)

+ type Cluster struct

+ FetchSystemInfo func(context.Context) (*kubedef.SystemInfo, error)

+ func ConnectToCluster(ctx context.Context, config cfg.Configuration) (*Cluster, error)

+ func (r *Cluster) AttachTerminal(ctx context.Context, reference *runtimepb.ContainerReference, ...) error

+ func (r *Cluster) DeleteAllRecursively(ctx context.Context, wait bool, progress io.Writer) (bool, error)

+ func (r *Cluster) EnsureState(ctx context.Context, key string) (any, error)

+ func (r *Cluster) FetchDiagnostics(ctx context.Context, reference *runtimepb.ContainerReference) (*runtimepb.Diagnostics, error)

+ func (r *Cluster) FetchLogsTo(ctx context.Context, w io.Writer, reference *runtimepb.ContainerReference, ...) error

+ func (r *Cluster) ForwardIngress(ctx context.Context, localAddrs []string, localPort int, ...) (io.Closer, error)

+ func (r *Cluster) PrepareCluster(ctx context.Context) (*runtime.DeploymentPlan, error)

+ func (r *Cluster) RunAttachedOpts(ctx context.Context, ns, name string, runOpts runtime.ContainerRunOpts, ...) error

+ func (r *Cluster) StartAndBlockPortFwd(ctx context.Context, args StartAndBlockPortFwdArgs) error

+ func (r *Cluster) SystemInfo(ctx context.Context) (*kubedef.SystemInfo, error)

+ func (r *Cluster) UnmatchedTargetPlatforms(ctx context.Context) ([]specs.Platform, error)

+ func (u *Cluster) Bind(env cfg.Context) (runtime.ClusterNamespace, error)

+ func (u *Cluster) Class() runtime.Class

+ func (u *Cluster) Planner(env cfg.Context) runtime.Planner

+ func (u *Cluster) PreparedClient() client.Prepared

+ func (u *Cluster) RESTConfig() *rest.Config

+ func (u *Cluster) RawDialServer(ctx context.Context, ns string, podLabels map[string]string, containerPort int) (net.Conn, error)

+ func (u *Cluster) RawForwardPort(ctx context.Context, desc, ns string, podLabels map[string]string, ...) (io.Closer, error)

+ type ClusterAttachedState struct

+ func (r *ClusterAttachedState) EnsureState(ctx context.Context, stateKey string, config cfg.Configuration, ...) (any, error)

+ type ClusterNamespace struct

+ func ConnectToNamespace(ctx context.Context, env cfg.Context) (*ClusterNamespace, error)

+ func (cn *ClusterNamespace) Cluster() runtime.Cluster

+ func (cn *ClusterNamespace) Planner() runtime.Planner

+ func (r *ClusterNamespace) DeleteDeployable(ctx context.Context, deployable runtime.Deployable) error

+ func (r *ClusterNamespace) DeleteRecursively(ctx context.Context, wait bool) (bool, error)

+ func (r *ClusterNamespace) DeployedConfigImageID(ctx context.Context, server runtime.Deployable) (oci.ImageID, error)

+ func (r *ClusterNamespace) DialServer(ctx context.Context, server runtime.Deployable, containerPort int32) (net.Conn, error)

+ func (r *ClusterNamespace) FetchEnvironmentDiagnostics(ctx context.Context) (*storage.EnvironmentDiagnostics, error)

+ func (r *ClusterNamespace) ForwardPort(ctx context.Context, server runtime.Deployable, containerPort int32, ...) (io.Closer, error)

+ func (r *ClusterNamespace) KubeConfig() kubedef.KubeConfig

+ func (r *ClusterNamespace) Observe(ctx context.Context, srv runtime.Deployable, opts runtime.ObserveOpts, ...) error

+ func (r *ClusterNamespace) ResolveContainers(ctx context.Context, object runtime.Deployable) ([]*runtimepb.ContainerReference, error)

+ func (r *ClusterNamespace) StartTerminal(ctx context.Context, server runtime.Deployable, rio runtime.TerminalIO, ...) error

+ func (r *ClusterNamespace) WaitForTermination(ctx context.Context, object runtime.Deployable) ([]runtime.ContainerStatus, error)

+ type Planner struct

+ func NewPlanner(env cfg.Context, ...) Planner

+ func (r Planner) ComputeBaseNaming(*fnschema.Naming) (*fnschema.ComputedNaming, error)

+ func (r Planner) KubernetesNamespace() string

+ func (r Planner) Namespace() runtime.Namespace

+ func (r Planner) PlanDeployment(ctx context.Context, d runtime.DeploymentSpec) (*runtime.DeploymentPlan, error)

+ func (r Planner) PlanIngress(ctx context.Context, stack *fnschema.Stack, ...) (*runtime.DeploymentPlan, error)

+ func (r Planner) Planner() runtime.Planner

+ func (r Planner) PrepareProvision(ctx context.Context) (*rtypes.ProvisionProps, error)

+ func (r Planner) TargetPlatforms(ctx context.Context) ([]specs.Platform, error)

+ func (r Planner) UniqueID() string

+ type PodResolver interface

+ Resolve func(context.Context) (v1.Pod, error)

+ type ProvideOverrideFunc func(context.Context, cfg.Configuration) (runtime.Class, error)

+ type StartAndBlockPortFwdArgs struct

+ ContainerPort int

+ Identifier string

+ LocalAddrs []string

+ LocalPort int

+ Namespace string

+ PodResolver PodResolver

+ ReportPorts func(runtime.ForwardedPort)