kubernetes

Documentation

Index

• type JobDispatcher
  • func New(ctx context.Context, pluginData map[string]string, ...) (*JobDispatcher, error)
  • func (j *JobDispatcher) DispatchJob(ctx context.Context, jobID string, token string) (string, error)

Types

type JobDispatcher

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

JobDispatcher uses a kubernetes client to dispatch jobs

func New

func New(ctx context.Context, pluginData map[string]string, discoveryProtocolHost string, logger logger.Logger) (*JobDispatcher, error)

New creates a JobDispatcher

func (*JobDispatcher) DispatchJob

func (j *JobDispatcher) DispatchJob(ctx context.Context, jobID string, token string) (string, error)

DispatchJob will start a kubernetes batch job to execute the job