docker

Documentation

Index

• Constants
• type DockerClient
  • func NewDockerClient() (*DockerClient, error)
  • func NewSimpleDockerClient() (*DockerClient, error)
  • func (client *DockerClient) CreateDockerInstance(podInfo *kubernetes.PodInfo) (string, error)
  • func (client *DockerClient) Execute(dockerId string, command string) (string, error)
  • func (client *DockerClient) GetDockerInstanceLog(dockerId string) (io.ReadCloser, error)
  • func (client *DockerClient) GetName(podInfo *kubernetes.PodInfo) string
  • func (client *DockerClient) IsDockerInstanceRunning(dockerId string) bool
  • func (client *DockerClient) ListDockerInstances(name string) ([]*DockerInstanceInfo, error)
  • func (client *DockerClient) PullImage(ctx context.Context, imageName string) error
  • func (client *DockerClient) RemoveDockerInstance(dockerId string, podName string)
  • func (client *DockerClient) StopDockerInstance(dockerId string, podName string)
• type DockerInstanceInfo
• type EnvoyManager
  • func NewEnvoyManager(k8sManager *kubernetes.K8sResourceManager) (*EnvoyManager, error)
  • func (manager *EnvoyManager) CheckExistingEnvoy()
  • func (manager *EnvoyManager) PodAdded(pod *kubernetes.PodInfo)
  • func (manager *EnvoyManager) PodDeleted(pod *kubernetes.PodInfo)
  • func (manager *EnvoyManager) PodUpdated(oldPod, newPod *kubernetes.PodInfo)
  • func (manager *EnvoyManager) PodValid(pod *kubernetes.PodInfo) bool

Constants

const (
	DOCKER_LABEL_NAMESPACE = "traffic.envoy.namespace"
	DOCKER_LABEL_POD       = "traffic.envoy.pod"
	DOCKER_LABEL_PROXY     = "traffic.envoy.proxy"
)

const (
	TRAFFIC_INGRESS_PROXY = "ingress"
)

Types

type DockerClient

type DockerClient struct {
	ProxyPort           string
	ControlPlanePort    string
	ControlPlaneService string
	ProxyManagePort     string
	ProxyUID            string
	ProxyImage          string
	ZipkinService       string
	ZipkinPort          string
	// contains filtered or unexported fields
}

func NewDockerClient

func NewDockerClient() (*DockerClient, error)

func NewSimpleDockerClient

func NewSimpleDockerClient() (*DockerClient, error)

func (*DockerClient) CreateDockerInstance

func (client *DockerClient) CreateDockerInstance(podInfo *kubernetes.PodInfo) (string, error)

func (*DockerClient) Execute

func (client *DockerClient) Execute(dockerId string, command string) (string, error)

func (*DockerClient) GetDockerInstanceLog

func (client *DockerClient) GetDockerInstanceLog(dockerId string) (io.ReadCloser, error)

func (*DockerClient) GetName

func (client *DockerClient) GetName(podInfo *kubernetes.PodInfo) string

func (*DockerClient) IsDockerInstanceRunning

func (client *DockerClient) IsDockerInstanceRunning(dockerId string) bool

func (*DockerClient) ListDockerInstances

func (client *DockerClient) ListDockerInstances(name string) ([]*DockerInstanceInfo, error)

func (*DockerClient) PullImage

func (client *DockerClient) PullImage(ctx context.Context, imageName string) error

func (*DockerClient) RemoveDockerInstance

func (client *DockerClient) RemoveDockerInstance(dockerId string, podName string)

func (*DockerClient) StopDockerInstance

func (client *DockerClient) StopDockerInstance(dockerId string, podName string)

type DockerInstanceInfo

type DockerInstanceInfo struct {
	ID        string
	Namespace string
	Pod       string
	Status    string
	State     string
}

type EnvoyManager

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

func NewEnvoyManager

func NewEnvoyManager(k8sManager *kubernetes.K8sResourceManager) (*EnvoyManager, error)

func (*EnvoyManager) CheckExistingEnvoy

func (manager *EnvoyManager) CheckExistingEnvoy()

func (*EnvoyManager) PodAdded

func (manager *EnvoyManager) PodAdded(pod *kubernetes.PodInfo)

func (*EnvoyManager) PodDeleted

func (manager *EnvoyManager) PodDeleted(pod *kubernetes.PodInfo)

func (*EnvoyManager) PodUpdated

func (manager *EnvoyManager) PodUpdated(oldPod, newPod *kubernetes.PodInfo)

func (*EnvoyManager) PodValid

func (manager *EnvoyManager) PodValid(pod *kubernetes.PodInfo) bool