service

Documentation

Index

• Variables
• type GrpcServer
  • func NewGrpcServer(opts Options) *GrpcServer
  • func (s *GrpcServer) Start(ctx context.Context) error
• type Options

Variables

var Names = []string{
	"machine.v1alpha1.MachineService.ScanMachine",
	"machine.v1alpha1.MachineService.Install",
	"machine.v1alpha1.MachineService.ListMachines",
	"machine.v1alpha1.MachineService.UpdateMachineStatus",
	"machine.v1alpha1.MachineService.AddPackageVersion",
	"machine.v1alpha1.MachineService.SetPackageVersion",
	"machine.v1alpha1.MachineService.RemovePackageVersion",
	"machine.v1alpha1.MachineService.GetJob",
	"machinetype.v1alpha1.MachineTypeService.Scan",
	"machinetype.v1alpha1.MachineTypeService.ListMachineTypes",
	"machinetype.v1alpha1.MachineTypeService.UpdateMachineTypeStatus",
	"machinetype.v1alpha1.MachineTypeService.AddMachineGroup",
	"machinetype.v1alpha1.MachineTypeService.RemoveMachineGroup",
	"machinetype.v1alpha1.MachineTypeService.GetJob",
}

Types

type GrpcServer

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

func NewGrpcServer

func NewGrpcServer(opts Options) *GrpcServer

func (*GrpcServer) Start

func (s *GrpcServer) Start(ctx context.Context) error

type Options

type Options struct {
	Cfg  *rest.Config
	Log  *slog.Logger
	Host string
	Port int

	Namespace     string
	JobsConfig    string
	Workers       uint64
	Horizon       time.Duration
	QueueCapacity uint64
}