kubernetes

Documentation

Index

• func GetPodLogs(pod *apiv1.Pod, handler EventHandler, ctx context.Context) (chan bool, error)
• func NewConnector() *connector
• func NewCreator() *creator
• func NewDeleter() *deleter
• func NewGetter() *getter
• func ToContainerId(containerName string, pod *apiv1.Pod) (string, error)
• type Connector
• type Creator
• type Deleter
• type EventHandler
• type Getter

Functions

func GetPodLogs

func GetPodLogs(pod *apiv1.Pod, handler EventHandler, ctx context.Context) (chan bool, error)

func NewConnector

func NewConnector() *connector

NewConnector returns new implementation of Connector

func NewCreator

func NewCreator() *creator

NewCreator returns new implementation of Creator

func NewDeleter

func NewDeleter() *deleter

NewDeleter returns new implementation of Deleter

func NewGetter

func NewGetter() *getter

NewGetter returns new implementation of Getter

func ToContainerId

func ToContainerId(containerName string, pod *apiv1.Pod) (string, error)

Types

type Connector

type Connector interface {
	Connect(clientGetter genericclioptions.RESTClientGetter) (string, error)
}

type Creator

type Creator interface {
	CreateProfilingJob(targetPod *v1.Pod, cfg *config.ProfilerConfig, ctx context.Context) (string, *batchv1.Job, error)
}

type Deleter

type Deleter interface {
	DeleteProfilingJob(job *batchv1.Job, targetDetails *config.TargetConfig, ctx context.Context) error
}

type EventHandler

type EventHandler interface {
	Handle(events chan string, done chan bool, ctx context.Context)
}

type Getter

type Getter interface {
	GetPod(podName, namespace string, ctx context.Context) (*apiv1.Pod, error)
	GetProfilingPod(cfg *config.ProfilerConfig, ctx context.Context) (*apiv1.Pod, error)
}