local

Documentation

Index

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

Types

type JobDispatcher

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

JobDispatcher is used for debugging jobs and should not be used in production

func New

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

New creates a JobDispatcher

func (*JobDispatcher) DispatchJob

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

DispatchJob will launch a local job executor that can be used to facilitate debugging