kubernetes

Documentation

Index

• func KubeConfig() string
• type Client
  • func NewClient(kubeconfig string, httpClient *http.Client) Client
• type MockClient
  • func (m *MockClient) ExecuteJob(jobName string, envMap map[string]string) (string, error)
  • func (m *MockClient) JobExecutionStatus(jobExecutionID string) (string, error)
  • func (m *MockClient) StreamJobLogs(jobName string) (io.ReadCloser, error)

Functions

func KubeConfig

func KubeConfig() string

Types

type Client

type Client interface {
	ExecuteJob(string, map[string]string) (string, error)
	StreamJobLogs(string) (io.ReadCloser, error)
	JobExecutionStatus(string) (string, error)
}

func NewClient

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

type MockClient

type MockClient struct {
	mock.Mock
}

func (*MockClient) ExecuteJob

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

func (*MockClient) JobExecutionStatus

func (m *MockClient) JobExecutionStatus(jobExecutionID string) (string, error)

func (*MockClient) StreamJobLogs

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