server

Documentation

Index

• func InitializeServer(isInCluster bool) (*grpc.Server, error)
• func New(logger *zap.Logger, scheduler sc.Scheduler) *grpc.Server
• type K8SgRPC
  • func (s *K8SgRPC) Add(ctx context.Context, req *jobidl.AddJobRequest) (*jobidl.AddJobResponse, error)

Functions

func InitializeServer

func InitializeServer(isInCluster bool) (*grpc.Server, error)

func New

func New(logger *zap.Logger, scheduler sc.Scheduler) *grpc.Server

New instance of the GRPC server

Types

type K8SgRPC

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

K8SgRPC an implementation of the grpc server

func (*K8SgRPC) Add

func (s *K8SgRPC) Add(ctx context.Context, req *jobidl.AddJobRequest) (*jobidl.AddJobResponse, error)

Add add a new job to the scheduler