azure-batch: github.com/virtual-kubelet/azure-batch Index | Files

package azurebatch

import "github.com/virtual-kubelet/azure-batch"

Index

Package Files

batch.go batch_helpers.go batch_status.go errors.go

type Config Uses

type Config struct {
    ClientID        string
    ClientSecret    string
    SubscriptionID  string
    TenantID        string
    ResourceGroup   string
    PoolID          string
    JobID           string
    AccountName     string
    AccountLocation string
}

Config - Basic azure config used to interact with ARM resources.

type ConfigError Uses

type ConfigError struct {
    CurrentConfig *Config
    ErrorDetails  string
}

ConfigError - Error when reading configuration values.

func (*ConfigError) Error Uses

func (e *ConfigError) Error() string

type Provider Uses

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

Provider the base struct for the Azure Batch provider

func NewBatchProvider Uses

func NewBatchProvider(configString string, rm *manager.ResourceManager, nodeName, operatingSystem string, internalIP string, daemonEndpointPort int32) (*Provider, error)

NewBatchProvider Creates a batch provider

func NewBatchProviderFromConfig Uses

func NewBatchProviderFromConfig(config *Config, rm *manager.ResourceManager, nodeName, operatingSystem string, internalIP string, daemonEndpointPort int32) (*Provider, error)

NewBatchProviderFromConfig Creates a batch provider

func (*Provider) Capacity Uses

func (p *Provider) Capacity(ctx context.Context) v1.ResourceList

Capacity returns a resource list containing the capacity limits

func (*Provider) CreatePod Uses

func (p *Provider) CreatePod(ctx context.Context, pod *v1.Pod) error

CreatePod accepts a Pod definition

func (*Provider) DeletePod Uses

func (p *Provider) DeletePod(ctx context.Context, pod *v1.Pod) error

DeletePod accepts a Pod definition

func (*Provider) GetContainerLogs Uses

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

GetContainerLogs returns the logs of a container running in a pod by name.

func (*Provider) GetPod Uses

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

GetPod returns a pod by name

func (*Provider) GetPodFullName Uses

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

Get full pod name as defined in the provider context TODO: Implementation

func (*Provider) GetPodStatus Uses

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

GetPodStatus retrieves the status of a given pod by name.

func (*Provider) GetPods Uses

func (p *Provider) GetPods(ctx context.Context) ([]*v1.Pod, error)

GetPods retrieves a list of all pods scheduled to run.

func (*Provider) NodeAddresses Uses

func (p *Provider) NodeAddresses(ctx context.Context) []v1.NodeAddress

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

func (*Provider) NodeConditions Uses

func (p *Provider) NodeConditions(ctx context.Context) []v1.NodeCondition

NodeConditions returns a list of conditions (Ready, OutOfDisk, etc), for updates to the node status within Kubernetes.

func (*Provider) NodeDaemonEndpoints Uses

func (p *Provider) NodeDaemonEndpoints(ctx context.Context) *v1.NodeDaemonEndpoints

NodeDaemonEndpoints returns NodeDaemonEndpoints for the node status within Kubernetes.

func (*Provider) OperatingSystem Uses

func (p *Provider) OperatingSystem() string

OperatingSystem returns the operating system for this provider.

func (*Provider) RunInContainer Uses

func (p *Provider) RunInContainer(ctx context.Context, namespace, name, container 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. TODO: Implementation

func (*Provider) UpdatePod Uses

func (p *Provider) UpdatePod(ctx context.Context, pod *v1.Pod) error

UpdatePod accepts a Pod definition

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