provider

Jun 21, 2023

Changes in this version

type ACIProvider

+ func (p *ACIProvider) AttachToContainer(ctx context.Context, namespace string, podName string, containerName string, ...) error

+ func (p *ACIProvider) FetchPodEvents(ctx context.Context, pod *v1.Pod, ...) error

+ func (p *ACIProvider) PortForward(ctx context.Context, namespace, pod string, port int32, ...) error

type PodsTrackerHandler

+ FetchPodEvents func(ctx context.Context, pod *v1.Pod, ...) error

Oct 18, 2022

Changes in this version

+ const AzureFileDriverName

+ const LogAnalyticsMetadataKeyClusterResourceID

+ const LogAnalyticsMetadataKeyNodeName

+ func NewAKSCredential(p string) (*aksCredential, error)

+ type ACIProvider struct

+ func NewACIProvider(ctx context.Context, config string, azConfig auth.Config, ...) (*ACIProvider, error)

+ func (p *ACIProvider) CleanupPod(ctx context.Context, ns, name string) error

+ func (p *ACIProvider) ConfigureNode(ctx context.Context, node *v1.Node)

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

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

+ func (p *ACIProvider) FetchPodStatus(ctx context.Context, ns, name string) (*v1.PodStatus, error)

+ func (p *ACIProvider) GetContainerLogs(ctx context.Context, namespace, podName, containerName string, ...) (io.ReadCloser, error)

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

+ func (p *ACIProvider) GetPodFullName(namespace string, pod string) string

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

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

+ func (p *ACIProvider) ListActivePods(ctx context.Context) ([]PodIdentifier, error)

+ func (p *ACIProvider) NotifyPods(ctx context.Context, notifierCb func(*v1.Pod))

+ func (p *ACIProvider) Ping(ctx context.Context) error

+ func (p *ACIProvider) RunInContainer(ctx context.Context, namespace, name, container string, cmd []string, ...) error

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

+ type AuthConfig struct

+ Auth string

+ Email string

+ IdentityToken string

+ Password string

+ RegistryToken string

+ ServerAddress string

+ Username string

+ type DockerConfig map[string]DockerConfigEntry

+ type DockerConfigEntry struct

+ Email string

+ Password string

+ Username string

+ func (ident *DockerConfigEntry) UnmarshalJSON(data []byte) error

+ func (ident DockerConfigEntry) MarshalJSON() ([]byte, error)

+ type DockerConfigJSON struct

+ Auths DockerConfig

+ HTTPHeaders map[string]string

+ type PodIdentifier struct

+ type PodsTracker struct

+ func (pt *PodsTracker) StartTracking(ctx context.Context)

+ func (pt *PodsTracker) UpdatePodStatus(ns, name string, updateHandler func(*v1.PodStatus), forceUpdate bool) error

+ type PodsTrackerHandler interface

+ CleanupPod func(ctx context.Context, ns, name string) error

+ FetchPodStatus func(ctx context.Context, ns, name string) (*v1.PodStatus, error)

+ ListActivePods func(ctx context.Context) ([]PodIdentifier, error)