server

package
v0.0.0-...-9bfccdf Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 22, 2023 License: GPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Options

type Options struct {
	ListenAddress   string
	CaCertFile      string
	CertFile        string
	KeyFile         string
	AuthMiddlewares []auth.Middleware
}

type Server

type Server struct {
	Options
	jobv1.UnsafeJobServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(runtime jobs.Runtime, options Options) *Server

func (*Server) List

func (s *Server) List(ctx context.Context, _ *emptypb.Empty) (*jobv1.JobIdList, error)

ListJobs implements v1.JobServer.

func (*Server) ListenAndServe

func (s *Server) ListenAndServe(ctx context.Context) error

func (*Server) Output

func (s *Server) Output(id *jobv1.JobId, stream jobv1.Job_OutputServer) error

Output implements v1.JobServer.

func (*Server) Start

func (s *Server) Start(ctx context.Context, in *jobv1.JobSpec) (*jobv1.JobId, error)

Start implements v1.JobServer.

func (*Server) Status

func (s *Server) Status(ctx context.Context, id *jobv1.JobId) (*jobv1.JobStatus, error)

GetStatus implements v1.JobServer.

func (*Server) Stop

func (s *Server) Stop(ctx context.Context, id *jobv1.JobId) (*emptypb.Empty, error)

Stop implements v1.JobServer.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL