machinev1alpha1connect

Documentation

Index

• Constants
• func NewMachineServiceHandler(svc MachineServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)
• type MachineServiceClient
  • func NewMachineServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) MachineServiceClient
• type MachineServiceHandler
• type UnimplementedMachineServiceHandler
  • func (UnimplementedMachineServiceHandler) AddPackageVersion(context.Context, *connect.Request[v1alpha1.AddPackageVersionRequest]) (*connect.Response[v1alpha1.AddPackageVersionResponse], error)
  • func (UnimplementedMachineServiceHandler) GetJob(context.Context, *connect.Request[v1alpha1.GetJobRequest]) (*connect.Response[v1alpha1.GetJobResponse], error)
  • func (UnimplementedMachineServiceHandler) Install(context.Context, *connect.Request[v1alpha1.InstallRequest]) (*connect.Response[v1alpha1.InstallResponse], error)
  • func (UnimplementedMachineServiceHandler) ListMachines(context.Context, *connect.Request[v1alpha1.ListMachinesRequest]) (*connect.Response[v1alpha1.ListMachinesResponse], error)
  • func (UnimplementedMachineServiceHandler) RemovePackageVersion(context.Context, *connect.Request[v1alpha1.RemovePackageVersionRequest]) (*connect.Response[v1alpha1.RemovePackageVersionResponse], error)
  • func (UnimplementedMachineServiceHandler) ScanMachine(context.Context, *connect.Request[v1alpha1.ScanMachineRequest]) (*connect.Response[v1alpha1.ScanMachineResponse], error)
  • func (UnimplementedMachineServiceHandler) SetPackageVersion(context.Context, *connect.Request[v1alpha1.SetPackageVersionRequest]) (*connect.Response[v1alpha1.SetPackageVersionResponse], error)
  • func (UnimplementedMachineServiceHandler) UpdateMachineStatus(context.Context, *connect.Request[v1alpha1.UpdateMachineStatusRequest]) (*connect.Response[v1alpha1.UpdateMachineStatusResponse], error)

Constants

const (
	// MachineServiceScanMachineProcedure is the fully-qualified name of the MachineService's
	// ScanMachine RPC.
	MachineServiceScanMachineProcedure = "/machine.v1alpha1.MachineService/ScanMachine"
	// MachineServiceInstallProcedure is the fully-qualified name of the MachineService's Install RPC.
	MachineServiceInstallProcedure = "/machine.v1alpha1.MachineService/Install"
	// MachineServiceUpdateMachineStatusProcedure is the fully-qualified name of the MachineService's
	// UpdateMachineStatus RPC.
	MachineServiceUpdateMachineStatusProcedure = "/machine.v1alpha1.MachineService/UpdateMachineStatus"
	// MachineServiceListMachinesProcedure is the fully-qualified name of the MachineService's
	// ListMachines RPC.
	MachineServiceListMachinesProcedure = "/machine.v1alpha1.MachineService/ListMachines"
	// MachineServiceAddPackageVersionProcedure is the fully-qualified name of the MachineService's
	// AddPackageVersion RPC.
	MachineServiceAddPackageVersionProcedure = "/machine.v1alpha1.MachineService/AddPackageVersion"
	// MachineServiceSetPackageVersionProcedure is the fully-qualified name of the MachineService's
	// SetPackageVersion RPC.
	MachineServiceSetPackageVersionProcedure = "/machine.v1alpha1.MachineService/SetPackageVersion"
	// MachineServiceRemovePackageVersionProcedure is the fully-qualified name of the MachineService's
	// RemovePackageVersion RPC.
	MachineServiceRemovePackageVersionProcedure = "/machine.v1alpha1.MachineService/RemovePackageVersion"
	// MachineServiceGetJobProcedure is the fully-qualified name of the MachineService's GetJob RPC.
	MachineServiceGetJobProcedure = "/machine.v1alpha1.MachineService/GetJob"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

const (
	// MachineServiceName is the fully-qualified name of the MachineService service.
	MachineServiceName = "machine.v1alpha1.MachineService"
)

Functions

func NewMachineServiceHandler

func NewMachineServiceHandler(svc MachineServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewMachineServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type MachineServiceClient

type MachineServiceClient interface {
	ScanMachine(context.Context, *connect.Request[v1alpha1.ScanMachineRequest]) (*connect.Response[v1alpha1.ScanMachineResponse], error)
	Install(context.Context, *connect.Request[v1alpha1.InstallRequest]) (*connect.Response[v1alpha1.InstallResponse], error)
	UpdateMachineStatus(context.Context, *connect.Request[v1alpha1.UpdateMachineStatusRequest]) (*connect.Response[v1alpha1.UpdateMachineStatusResponse], error)
	ListMachines(context.Context, *connect.Request[v1alpha1.ListMachinesRequest]) (*connect.Response[v1alpha1.ListMachinesResponse], error)
	AddPackageVersion(context.Context, *connect.Request[v1alpha1.AddPackageVersionRequest]) (*connect.Response[v1alpha1.AddPackageVersionResponse], error)
	SetPackageVersion(context.Context, *connect.Request[v1alpha1.SetPackageVersionRequest]) (*connect.Response[v1alpha1.SetPackageVersionResponse], error)
	RemovePackageVersion(context.Context, *connect.Request[v1alpha1.RemovePackageVersionRequest]) (*connect.Response[v1alpha1.RemovePackageVersionResponse], error)
	GetJob(context.Context, *connect.Request[v1alpha1.GetJobRequest]) (*connect.Response[v1alpha1.GetJobResponse], error)
}

MachineServiceClient is a client for the machine.v1alpha1.MachineService service.

func NewMachineServiceClient

func NewMachineServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) MachineServiceClient

NewMachineServiceClient constructs a client for the machine.v1alpha1.MachineService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type MachineServiceHandler

type MachineServiceHandler interface {
	ScanMachine(context.Context, *connect.Request[v1alpha1.ScanMachineRequest]) (*connect.Response[v1alpha1.ScanMachineResponse], error)
	Install(context.Context, *connect.Request[v1alpha1.InstallRequest]) (*connect.Response[v1alpha1.InstallResponse], error)
	UpdateMachineStatus(context.Context, *connect.Request[v1alpha1.UpdateMachineStatusRequest]) (*connect.Response[v1alpha1.UpdateMachineStatusResponse], error)
	ListMachines(context.Context, *connect.Request[v1alpha1.ListMachinesRequest]) (*connect.Response[v1alpha1.ListMachinesResponse], error)
	AddPackageVersion(context.Context, *connect.Request[v1alpha1.AddPackageVersionRequest]) (*connect.Response[v1alpha1.AddPackageVersionResponse], error)
	SetPackageVersion(context.Context, *connect.Request[v1alpha1.SetPackageVersionRequest]) (*connect.Response[v1alpha1.SetPackageVersionResponse], error)
	RemovePackageVersion(context.Context, *connect.Request[v1alpha1.RemovePackageVersionRequest]) (*connect.Response[v1alpha1.RemovePackageVersionResponse], error)
	GetJob(context.Context, *connect.Request[v1alpha1.GetJobRequest]) (*connect.Response[v1alpha1.GetJobResponse], error)
}

MachineServiceHandler is an implementation of the machine.v1alpha1.MachineService service.

type UnimplementedMachineServiceHandler

type UnimplementedMachineServiceHandler struct{}

UnimplementedMachineServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedMachineServiceHandler) AddPackageVersion

func (UnimplementedMachineServiceHandler) AddPackageVersion(context.Context, *connect.Request[v1alpha1.AddPackageVersionRequest]) (*connect.Response[v1alpha1.AddPackageVersionResponse], error)

func (UnimplementedMachineServiceHandler) GetJob

func (UnimplementedMachineServiceHandler) GetJob(context.Context, *connect.Request[v1alpha1.GetJobRequest]) (*connect.Response[v1alpha1.GetJobResponse], error)

func (UnimplementedMachineServiceHandler) Install

func (UnimplementedMachineServiceHandler) Install(context.Context, *connect.Request[v1alpha1.InstallRequest]) (*connect.Response[v1alpha1.InstallResponse], error)

func (UnimplementedMachineServiceHandler) ListMachines

func (UnimplementedMachineServiceHandler) ListMachines(context.Context, *connect.Request[v1alpha1.ListMachinesRequest]) (*connect.Response[v1alpha1.ListMachinesResponse], error)

func (UnimplementedMachineServiceHandler) RemovePackageVersion

func (UnimplementedMachineServiceHandler) RemovePackageVersion(context.Context, *connect.Request[v1alpha1.RemovePackageVersionRequest]) (*connect.Response[v1alpha1.RemovePackageVersionResponse], error)

func (UnimplementedMachineServiceHandler) ScanMachine

func (UnimplementedMachineServiceHandler) ScanMachine(context.Context, *connect.Request[v1alpha1.ScanMachineRequest]) (*connect.Response[v1alpha1.ScanMachineResponse], error)

func (UnimplementedMachineServiceHandler) SetPackageVersion

func (UnimplementedMachineServiceHandler) SetPackageVersion(context.Context, *connect.Request[v1alpha1.SetPackageVersionRequest]) (*connect.Response[v1alpha1.SetPackageVersionResponse], error)

func (UnimplementedMachineServiceHandler) UpdateMachineStatus

func (UnimplementedMachineServiceHandler) UpdateMachineStatus(context.Context, *connect.Request[v1alpha1.UpdateMachineStatusRequest]) (*connect.Response[v1alpha1.UpdateMachineStatusResponse], error)