jobapi

Documentation

Index

• type Server
  • func New(ms metascheduler.MetaScheduler, resourceManager *lock.ResourceManager, ...) *Server
  • func (s *Server) SetJobStatus(ctx context.Context, req *supervisorv1alpha1.SetJobStatusRequest) (*supervisorv1alpha1.SetJobStatusResponse, error)

Types

type Server

type Server struct {
	supervisorv1alpha1.UnimplementedJobAPIServer

	Timeout time.Duration
	// Delay between tries
	Delay time.Duration
	// contains filtered or unexported fields
}

func New

func New(
	ms metascheduler.MetaScheduler,
	resourceManager *lock.ResourceManager,
	scheduler scheduler.Scheduler,
) *Server

func (*Server) SetJobStatus

func (s *Server) SetJobStatus(
	ctx context.Context,
	req *supervisorv1alpha1.SetJobStatusRequest,
) (*supervisorv1alpha1.SetJobStatusResponse, error)

SetJobStatus to the ethereum network