stateless

Documentation

Index

• func InitV1AlphaJobServiceHandler(d *yarpc.Dispatcher, jobStore storage.JobStore, ...)
• func NewTestServiceHandler() *serviceHandler

Functions

func InitV1AlphaJobServiceHandler

func InitV1AlphaJobServiceHandler(
	d *yarpc.Dispatcher,
	jobStore storage.JobStore,
	updateStore storage.UpdateStore,
	taskStore storage.TaskStore,
	ormStore *ormobjects.Store,
	jobFactory cached.JobFactory,
	goalStateDriver goalstate.Driver,
	candidate leader.Candidate,
	jobSvcCfg jobsvc.Config,
	activeRMTasks activermtask.ActiveRMTasks,
)

InitV1AlphaJobServiceHandler initializes the Job Manager V1Alpha Service Handler

func NewTestServiceHandler

func NewTestServiceHandler() *serviceHandler

NewTestServiceHandler returns an empty new ServiceHandler ptr for testing.