service

Documentation

Index

• type FakeJobExecutor
  • func NewFake() *FakeJobExecutor
  • func (svc *FakeJobExecutor) List(ctx context.Context, req *pb.ListRequest) (*pb.ListResponse, error)
  • func (svc *FakeJobExecutor) Logs(req *pb.LogsRequest, stream pb.JobExecutor_LogsServer) error
  • func (svc *FakeJobExecutor) RegisterWith(gs grpc.ServiceRegistrar)
  • func (svc *FakeJobExecutor) Run(ctx context.Context, req *pb.RunRequest) (*pb.RunResponse, error)
  • func (svc *FakeJobExecutor) Status(ctx context.Context, req *pb.StatusRequest) (*pb.StatusResponse, error)
  • func (svc *FakeJobExecutor) Stop(ctx context.Context, req *pb.StopRequest) (*pb.StopResponse, error)
• type JobExecutor
  • func NewJobExecutor(done chan<- struct{}, argMaker job.ArgMaker, admins []string) *JobExecutor
  • func (svc *JobExecutor) List(ctx context.Context, req *pb.ListRequest) (*pb.ListResponse, error)
  • func (svc *JobExecutor) Logs(req *pb.LogsRequest, stream pb.JobExecutor_LogsServer) error
  • func (svc *JobExecutor) RegisterWith(gs grpc.ServiceRegistrar)
  • func (svc *JobExecutor) Run(ctx context.Context, req *pb.RunRequest) (*pb.RunResponse, error)
  • func (svc *JobExecutor) Shutdown(ctx context.Context, req *pb.ShutdownRequest) (*pb.ShutdownResponse, error)
  • func (svc *JobExecutor) Status(ctx context.Context, req *pb.StatusRequest) (*pb.StatusResponse, error)
  • func (svc *JobExecutor) Stop(ctx context.Context, req *pb.StopRequest) (*pb.StopResponse, error)

Types

type FakeJobExecutor

type FakeJobExecutor struct {
	pb.UnimplementedJobExecutorServer
}

func NewFake

func NewFake() *FakeJobExecutor

func (*FakeJobExecutor) List

func (svc *FakeJobExecutor) List(ctx context.Context, req *pb.ListRequest) (*pb.ListResponse, error)

func (*FakeJobExecutor) Logs

func (svc *FakeJobExecutor) Logs(req *pb.LogsRequest, stream pb.JobExecutor_LogsServer) error

func (*FakeJobExecutor) RegisterWith

func (svc *FakeJobExecutor) RegisterWith(gs grpc.ServiceRegistrar)

func (*FakeJobExecutor) Run

func (svc *FakeJobExecutor) Run(ctx context.Context, req *pb.RunRequest) (*pb.RunResponse, error)

func (*FakeJobExecutor) Status

func (svc *FakeJobExecutor) Status(ctx context.Context, req *pb.StatusRequest) (*pb.StatusResponse, error)

func (*FakeJobExecutor) Stop

func (svc *FakeJobExecutor) Stop(ctx context.Context, req *pb.StopRequest) (*pb.StopResponse, error)

type JobExecutor

type JobExecutor struct {
	pb.UnimplementedJobExecutorServer
	// contains filtered or unexported fields
}

func NewJobExecutor

func NewJobExecutor(done chan<- struct{}, argMaker job.ArgMaker, admins []string) *JobExecutor

func (*JobExecutor) List

func (svc *JobExecutor) List(ctx context.Context, req *pb.ListRequest) (*pb.ListResponse, error)

func (*JobExecutor) Logs

func (svc *JobExecutor) Logs(req *pb.LogsRequest, stream pb.JobExecutor_LogsServer) error

func (*JobExecutor) RegisterWith

func (svc *JobExecutor) RegisterWith(gs grpc.ServiceRegistrar)

func (*JobExecutor) Run

func (svc *JobExecutor) Run(ctx context.Context, req *pb.RunRequest) (*pb.RunResponse, error)

func (*JobExecutor) Shutdown

func (svc *JobExecutor) Shutdown(ctx context.Context, req *pb.ShutdownRequest) (*pb.ShutdownResponse, error)

func (*JobExecutor) Status

func (svc *JobExecutor) Status(ctx context.Context, req *pb.StatusRequest) (*pb.StatusResponse, error)

func (*JobExecutor) Stop

func (svc *JobExecutor) Stop(ctx context.Context, req *pb.StopRequest) (*pb.StopResponse, error)