tasks

Documentation

Index

• func New(ic *plugin.InitContext) (interface{}, error)
• type Service
  • func (s *Service) Checkpoint(ctx context.Context, r *api.CheckpointTaskRequest) (*api.CheckpointTaskResponse, error)
  • func (s *Service) CloseIO(ctx context.Context, r *api.CloseIORequest) (*google_protobuf.Empty, error)
  • func (s *Service) Create(ctx context.Context, r *api.CreateTaskRequest) (*api.CreateTaskResponse, error)
  • func (s *Service) Delete(ctx context.Context, r *api.DeleteTaskRequest) (*api.DeleteResponse, error)
  • func (s *Service) DeleteProcess(ctx context.Context, r *api.DeleteProcessRequest) (*api.DeleteResponse, error)
  • func (s *Service) Exec(ctx context.Context, r *api.ExecProcessRequest) (*google_protobuf.Empty, error)
  • func (s *Service) Get(ctx context.Context, r *api.GetRequest) (*api.GetResponse, error)
  • func (s *Service) Kill(ctx context.Context, r *api.KillRequest) (*google_protobuf.Empty, error)
  • func (s *Service) List(ctx context.Context, r *api.ListTasksRequest) (*api.ListTasksResponse, error)
  • func (s *Service) ListPids(ctx context.Context, r *api.ListPidsRequest) (*api.ListPidsResponse, error)
  • func (s *Service) Pause(ctx context.Context, r *api.PauseTaskRequest) (*google_protobuf.Empty, error)
  • func (s *Service) Register(server *grpc.Server) error
  • func (s *Service) ResizePty(ctx context.Context, r *api.ResizePtyRequest) (*google_protobuf.Empty, error)
  • func (s *Service) Resume(ctx context.Context, r *api.ResumeTaskRequest) (*google_protobuf.Empty, error)
  • func (s *Service) Start(ctx context.Context, r *api.StartRequest) (*api.StartResponse, error)
  • func (s *Service) Update(ctx context.Context, r *api.UpdateTaskRequest) (*google_protobuf.Empty, error)

Functions

func New

func New(ic *plugin.InitContext) (interface{}, error)

Types

type Service

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

func (*Service) Checkpoint

func (s *Service) Checkpoint(ctx context.Context, r *api.CheckpointTaskRequest) (*api.CheckpointTaskResponse, error)

func (*Service) CloseIO

func (s *Service) CloseIO(ctx context.Context, r *api.CloseIORequest) (*google_protobuf.Empty, error)

func (*Service) Create

func (s *Service) Create(ctx context.Context, r *api.CreateTaskRequest) (*api.CreateTaskResponse, error)

func (*Service) Delete

func (s *Service) Delete(ctx context.Context, r *api.DeleteTaskRequest) (*api.DeleteResponse, error)

func (*Service) DeleteProcess

func (s *Service) DeleteProcess(ctx context.Context, r *api.DeleteProcessRequest) (*api.DeleteResponse, error)

func (*Service) Exec

func (s *Service) Exec(ctx context.Context, r *api.ExecProcessRequest) (*google_protobuf.Empty, error)

func (*Service) Get

func (s *Service) Get(ctx context.Context, r *api.GetRequest) (*api.GetResponse, error)

func (*Service) Kill

func (s *Service) Kill(ctx context.Context, r *api.KillRequest) (*google_protobuf.Empty, error)

func (*Service) List

func (s *Service) List(ctx context.Context, r *api.ListTasksRequest) (*api.ListTasksResponse, error)

func (*Service) ListPids

func (s *Service) ListPids(ctx context.Context, r *api.ListPidsRequest) (*api.ListPidsResponse, error)

func (*Service) Pause

func (s *Service) Pause(ctx context.Context, r *api.PauseTaskRequest) (*google_protobuf.Empty, error)

func (*Service) Register

func (s *Service) Register(server *grpc.Server) error

func (*Service) ResizePty

func (s *Service) ResizePty(ctx context.Context, r *api.ResizePtyRequest) (*google_protobuf.Empty, error)

func (*Service) Resume

func (s *Service) Resume(ctx context.Context, r *api.ResumeTaskRequest) (*google_protobuf.Empty, error)

func (*Service) Start

func (s *Service) Start(ctx context.Context, r *api.StartRequest) (*api.StartResponse, error)

func (*Service) Update

func (s *Service) Update(ctx context.Context, r *api.UpdateTaskRequest) (*google_protobuf.Empty, error)