aws-fargate: github.com/virtual-kubelet/aws-fargate Index | Files | Directories

package aws

import "github.com/virtual-kubelet/aws-fargate"

Index

Package Files

config.go provider.go

type FargateProvider Uses

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

FargateProvider implements the virtual-kubelet provider interface.

func NewFargateProvider Uses

func NewFargateProvider(
    config string,
    rm *manager.ResourceManager,
    nodeName string,
    operatingSystem string,
    internalIP string,
    daemonEndpointPort int32) (*FargateProvider, error)

NewFargateProvider creates a new Fargate provider.

func (*FargateProvider) Capacity Uses

func (p *FargateProvider) Capacity(ctx context.Context) corev1.ResourceList

Capacity returns a resource list with the capacity constraints of the provider.

func (*FargateProvider) CreatePod Uses

func (p *FargateProvider) CreatePod(ctx context.Context, pod *corev1.Pod) error

CreatePod takes a Kubernetes Pod and deploys it within the Fargate provider.

func (*FargateProvider) DeletePod Uses

func (p *FargateProvider) DeletePod(ctx context.Context, pod *corev1.Pod) error

DeletePod takes a Kubernetes Pod and deletes it from the provider.

func (*FargateProvider) GetContainerLogs Uses

func (p *FargateProvider) GetContainerLogs(ctx context.Context, namespace, podName, containerName string, opts api.ContainerLogOpts) (io.ReadCloser, error)

GetContainerLogs retrieves the logs of a container by name from the provider.

func (*FargateProvider) GetPod Uses

func (p *FargateProvider) GetPod(ctx context.Context, namespace, name string) (*corev1.Pod, error)

GetPod retrieves a pod by name from the provider (can be cached).

func (*FargateProvider) GetPodFullName Uses

func (p *FargateProvider) GetPodFullName(namespace string, pod string) string

GetPodFullName retrieves the full pod name as defined in the provider context.

func (*FargateProvider) GetPodStatus Uses

func (p *FargateProvider) GetPodStatus(ctx context.Context, namespace, name string) (*corev1.PodStatus, error)

GetPodStatus retrieves the status of a pod by name from the provider.

func (*FargateProvider) GetPods Uses

func (p *FargateProvider) GetPods(ctx context.Context) ([]*corev1.Pod, error)

GetPods retrieves a list of all pods running on the provider (can be cached).

func (*FargateProvider) NodeAddresses Uses

func (p *FargateProvider) NodeAddresses(ctx context.Context) []corev1.NodeAddress

NodeAddresses returns a list of addresses for the node status within Kubernetes.

func (*FargateProvider) NodeConditions Uses

func (p *FargateProvider) NodeConditions(ctx context.Context) []corev1.NodeCondition

NodeConditions returns a list of conditions (Ready, OutOfDisk, etc), which is polled periodically to update the node status within Kubernetes.

func (*FargateProvider) NodeDaemonEndpoints Uses

func (p *FargateProvider) NodeDaemonEndpoints(ctx context.Context) *corev1.NodeDaemonEndpoints

NodeDaemonEndpoints returns NodeDaemonEndpoints for the node status within Kubernetes.

func (*FargateProvider) OperatingSystem Uses

func (p *FargateProvider) OperatingSystem() string

OperatingSystem returns the operating system the provider is for.

func (*FargateProvider) RunInContainer Uses

func (p *FargateProvider) RunInContainer(ctx context.Context, namespace, podName, containerName string, cmd []string, attach api.AttachIO) error

RunInContainer executes a command in a container in the pod, copying data between in/out/err and the container's stdin/stdout/stderr.

func (*FargateProvider) UpdatePod Uses

func (p *FargateProvider) UpdatePod(ctx context.Context, pod *corev1.Pod) error

UpdatePod takes a Kubernetes Pod and updates it within the provider.

Directories

PathSynopsis
fargate

Package aws imports 14 packages (graph). Updated 2019-06-25. Refresh now. Tools for package owners.