controller

Documentation

Index

• type Service
  • func NewService() *Service
  • func (s *Service) AddWorker(ctx context.Context, req *pb.AddWorkerRequest) (*pb.AddWorkerResponse, error)
  • func (s *Service) SetExecuteRequest(ctx context.Context, req *pb.ExecuteRequest) (*empty.Empty, error)
  • func (s *Service) SetPlugin(ctx context.Context, req *pb.DistributeRequest) (*pb.DistributeAllResponse, error)
  • func (s *Service) Start(ctx context.Context, req *pb.StartRequest) (*pb.StartResponse, error)
  • func (s *Service) Status(ctx context.Context, _ *empty.Empty) (*pb.StatusResponse, error)
  • func (s *Service) Stop(ctx context.Context, _ *empty.Empty) (*empty.Empty, error)
  • func (s *Service) Wait(req *pb.ControllerWaitRequest, stream pb.Controller_WaitServer) error

Types

type Service

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

func NewService

func NewService() *Service

func (*Service) AddWorker

func (s *Service) AddWorker(ctx context.Context, req *pb.AddWorkerRequest) (*pb.AddWorkerResponse, error)

func (*Service) SetExecuteRequest

func (s *Service) SetExecuteRequest(ctx context.Context, req *pb.ExecuteRequest) (*empty.Empty, error)

func (*Service) SetPlugin

func (s *Service) SetPlugin(ctx context.Context, req *pb.DistributeRequest) (*pb.DistributeAllResponse, error)

func (*Service) Start

func (s *Service) Start(ctx context.Context, req *pb.StartRequest) (*pb.StartResponse, error)

func (*Service) Status

func (s *Service) Status(ctx context.Context, _ *empty.Empty) (*pb.StatusResponse, error)

func (*Service) Stop

func (s *Service) Stop(ctx context.Context, _ *empty.Empty) (*empty.Empty, error)

func (*Service) Wait

func (s *Service) Wait(req *pb.ControllerWaitRequest, stream pb.Controller_WaitServer) error