server

Documentation

Index

• Constants
• type MachineClassRegistry
• type Options
• type Server
  • func New(opts Options) (*Server, error)
  • func (s *Server) AttachNetworkInterface(ctx context.Context, req *iri.AttachNetworkInterfaceRequest) (res *iri.AttachNetworkInterfaceResponse, retErr error)
  • func (s *Server) AttachVolume(ctx context.Context, req *iri.AttachVolumeRequest) (*iri.AttachVolumeResponse, error)
  • func (s *Server) CreateMachine(ctx context.Context, req *iri.CreateMachineRequest) (res *iri.CreateMachineResponse, retErr error)
  • func (s *Server) DeleteMachine(ctx context.Context, req *iri.DeleteMachineRequest) (*iri.DeleteMachineResponse, error)
  • func (s *Server) DetachNetworkInterface(ctx context.Context, req *iri.DetachNetworkInterfaceRequest) (*iri.DetachNetworkInterfaceResponse, error)
  • func (s *Server) DetachVolume(ctx context.Context, req *iri.DetachVolumeRequest) (*iri.DetachVolumeResponse, error)
  • func (s *Server) Exec(ctx context.Context, req *iri.ExecRequest) (*iri.ExecResponse, error)
  • func (s *Server) ListEvents(ctx context.Context, req *iri.ListEventsRequest) (*iri.ListEventsResponse, error)
  • func (s *Server) ListMachines(ctx context.Context, req *iri.ListMachinesRequest) (*iri.ListMachinesResponse, error)
  • func (s *Server) ServeExec(w http.ResponseWriter, req *http.Request, token string)
  • func (s *Server) Status(ctx context.Context, req *iri.StatusRequest) (*iri.StatusResponse, error)
  • func (s *Server) UpdateMachineAnnotations(ctx context.Context, req *iri.UpdateMachineAnnotationsRequest) (*iri.UpdateMachineAnnotationsResponse, error)
  • func (s *Server) UpdateMachinePower(ctx context.Context, req *iri.UpdateMachinePowerRequest) (*iri.UpdateMachinePowerResponse, error)
  • func (s *Server) Version(ctx context.Context, req *iri.VersionRequest) (*iri.VersionResponse, error)

Constants

const (
	StreamCreationTimeout = 30 * time.Second
	StreamIdleTimeout     = 2 * time.Minute
)

Types

type MachineClassRegistry

type MachineClassRegistry interface {
	Get(volumeClassName string) (*iri.MachineClass, bool)
	List() []*iri.MachineClass
}

type Options

type Options struct {
	// BaseURL is the base URL in form http(s)://host:port/path?query to produce request URLs relative to.
	BaseURL string

	Libvirt *libvirt.Libvirt

	IDGen idgen.IDGen

	MachineStore store.Store[*api.Machine]
	EventStore   machineevent.EventStore

	MachineClasses MachineClassRegistry

	VolumePlugins   *volume.PluginManager
	NetworkPlugins  providernetworkinterface.Plugin
	EnableHugepages bool
	GuestAgent      api.GuestAgent
}

type Server

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

func New

func New(opts Options) (*Server, error)

func (*Server) AttachNetworkInterface

func (s *Server) AttachNetworkInterface(ctx context.Context, req *iri.AttachNetworkInterfaceRequest) (res *iri.AttachNetworkInterfaceResponse, retErr error)

func (*Server) AttachVolume

func (s *Server) AttachVolume(ctx context.Context, req *iri.AttachVolumeRequest) (*iri.AttachVolumeResponse, error)

func (*Server) CreateMachine

func (s *Server) CreateMachine(ctx context.Context, req *iri.CreateMachineRequest) (res *iri.CreateMachineResponse, retErr error)

func (*Server) DeleteMachine

func (s *Server) DeleteMachine(ctx context.Context, req *iri.DeleteMachineRequest) (*iri.DeleteMachineResponse, error)

func (*Server) DetachNetworkInterface

func (s *Server) DetachNetworkInterface(
	ctx context.Context,
	req *iri.DetachNetworkInterfaceRequest,
) (*iri.DetachNetworkInterfaceResponse, error)

func (*Server) DetachVolume

func (s *Server) DetachVolume(ctx context.Context, req *iri.DetachVolumeRequest) (*iri.DetachVolumeResponse, error)

func (*Server) Exec

func (s *Server) Exec(ctx context.Context, req *iri.ExecRequest) (*iri.ExecResponse, error)

func (*Server) ListEvents

func (s *Server) ListEvents(ctx context.Context, req *iri.ListEventsRequest) (*iri.ListEventsResponse, error)

func (*Server) ListMachines

func (s *Server) ListMachines(ctx context.Context, req *iri.ListMachinesRequest) (*iri.ListMachinesResponse, error)

func (*Server) ServeExec

func (s *Server) ServeExec(w http.ResponseWriter, req *http.Request, token string)

func (*Server) Status

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

func (*Server) UpdateMachineAnnotations

func (s *Server) UpdateMachineAnnotations(ctx context.Context, req *iri.UpdateMachineAnnotationsRequest) (*iri.UpdateMachineAnnotationsResponse, error)

func (*Server) UpdateMachinePower

func (s *Server) UpdateMachinePower(ctx context.Context, req *iri.UpdateMachinePowerRequest) (*iri.UpdateMachinePowerResponse, error)

func (*Server) Version

func (s *Server) Version(ctx context.Context, req *iri.VersionRequest) (*iri.VersionResponse, error)