kubernetes

Oct 8, 2018

Changes in this version

+ func KubeConfig() string

+ type Client interface

+ ExecuteJob func(string, map[string]string) (string, error)

+ JobExecutionStatus func(string) (string, error)

+ StreamJobLogs func(string) (io.ReadCloser, error)

+ func NewClient(kubeconfig string, httpClient *http.Client) Client

+ type MockClient struct

+ func (m *MockClient) ExecuteJob(jobName string, envMap map[string]string) (string, error)

+ func (m *MockClient) JobExecutionStatus(JobNameSubmittedForExecution string) (string, error)

+ func (m *MockClient) StreamJobLogs(jobName string) (io.ReadCloser, error)