rexTaskQueue

type AnchoredJobService interface {
	Add(ctx context.Context, params *rexTypes.TaskQueueAnchoredJobAddReq) (code int32, result *rexTypes.TaskQueueAnchoredJobAddResp, err error)
	Remove(ctx context.Context, params *rexTypes.TaskQueueAnchoredJobRemoveReq) (code int32, result *rexTypes.TaskQueueAnchoredJobRemoveResp, err error)
}

type BaseService interface {
}

type DelayedJobService interface {
	Add(ctx context.Context, params *rexTypes.TaskQueueDelayedJobAddReq) (code int32, result *rexTypes.TaskQueueDelayedJobAddResp, err error)
	Cancel(ctx context.Context, params *rexTypes.TaskQueueDelayedJobCancelReq) (code int32, result *rexTypes.TaskQueueDelayedJobCancelResp, err error)
}

type PeriodicJobService interface {
	Add(ctx context.Context, params *rexTypes.TaskQueuePeriodicJobAddReq) (code int32, result *rexTypes.TaskQueuePeriodicJobAddResp, err error)
	Remove(ctx context.Context, params *rexTypes.TaskQueuePeriodicJobRemoveReq) (code int32, result *rexTypes.TaskQueuePeriodicJobRemoveResp, err error)
}

type TaskQueueService struct {
	BaseService
	PeriodicJobService PeriodicJobService
	AnchoredJobService AnchoredJobService
	DelayedJobService  DelayedJobService
}