docker

Documentation

Index

• type JobDispatcher
  • func New(pluginData map[string]string, discoveryProtocolHost 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 the local docker api to dispatch jobs

func New

func New(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 docker container to execute the job