api

Documentation

Index

• func CommonNameFromContext(ctx context.Context) (string, error)
• type Server
  • func NewServer(manager *job.Manager, log *zap.SugaredLogger) *Server
  • func (s Server) Output(req *jogv1.OutputRequest, srv jogv1.JobService_OutputServer) error
  • func (s Server) Start(ctx context.Context, req *jogv1.StartRequest) (*jogv1.StartResponse, error)
  • func (s Server) Status(ctx context.Context, req *jogv1.StatusRequest) (*jogv1.StatusResponse, error)
  • func (s Server) Stop(ctx context.Context, req *jogv1.StopRequest) (*jogv1.StopResponse, error)

Functions

func CommonNameFromContext

func CommonNameFromContext(ctx context.Context) (string, error)

CommonNameFromContext gets the common name from peer certificates in the context -- this is the username Note that for local development, this is set in the gencerts binary.

Types

type Server

type Server struct {
	jogv1.UnimplementedJobServiceServer
	// contains filtered or unexported fields
}

Server is the implementation of the grpc JobServiceServer

func NewServer

func NewServer(manager *job.Manager, log *zap.SugaredLogger) *Server

func (Server) Output

func (s Server) Output(req *jogv1.OutputRequest, srv jogv1.JobService_OutputServer) error

Output streams the output of a job

func (Server) Start

func (s Server) Start(ctx context.Context, req *jogv1.StartRequest) (*jogv1.StartResponse, error)

Start starts a new job

func (Server) Status

func (s Server) Status(ctx context.Context, req *jogv1.StatusRequest) (*jogv1.StatusResponse, error)

Status gets the status of a job

func (Server) Stop

func (s Server) Stop(ctx context.Context, req *jogv1.StopRequest) (*jogv1.StopResponse, error)

Stop stops a job