Documentation
¶
Index ¶
- type APIHandler
- type ConfigurableAPIHandler
- func (d *ConfigurableAPIHandler) Activate(ctx context.Context, req *os.ActivateRequest) (*os.ActivateResponse, error)
- func (d *ConfigurableAPIHandler) Get(ctx context.Context, req *gnmi.GetRequest) (*gnmi.GetResponse, error)
- func (d *ConfigurableAPIHandler) Install(req os.OS_InstallServer) error
- func (d *ConfigurableAPIHandler) RebootStatus(ctx context.Context, req *system.RebootStatusRequest) (*system.RebootStatusResponse, error)
- func (d *ConfigurableAPIHandler) Set(ctx context.Context, req *gnmi.SetRequest) (*gnmi.SetResponse, error)
- type DMSAPICommand
- type DMSServerMux
- type DPUNodeToPortListener
- type ListenerManager
- type Server
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type APIHandler ¶
type APIHandler interface {
os.OSServer
system.SystemServer
gnmi.GNMIServer
}
type ConfigurableAPIHandler ¶
type ConfigurableAPIHandler struct {
os.UnimplementedOSServer
system.UnimplementedSystemServer
gnmi.UnimplementedGNMIServer
sync.RWMutex
Config config.Config
// contains filtered or unexported fields
}
func (*ConfigurableAPIHandler) Activate ¶
func (d *ConfigurableAPIHandler) Activate(ctx context.Context, req *os.ActivateRequest) (*os.ActivateResponse, error)
func (*ConfigurableAPIHandler) Get ¶
func (d *ConfigurableAPIHandler) Get(ctx context.Context, req *gnmi.GetRequest) (*gnmi.GetResponse, error)
Get is a mock implementation of the DMS API. TODO: remove the whole DMS API mock because they are now used by the host agent rather than the provisioning controller.
func (*ConfigurableAPIHandler) Install ¶
func (d *ConfigurableAPIHandler) Install(req os.OS_InstallServer) error
func (*ConfigurableAPIHandler) RebootStatus ¶
func (d *ConfigurableAPIHandler) RebootStatus(ctx context.Context, req *system.RebootStatusRequest) (*system.RebootStatusResponse, error)
func (*ConfigurableAPIHandler) Set ¶
func (d *ConfigurableAPIHandler) Set(ctx context.Context, req *gnmi.SetRequest) (*gnmi.SetResponse, error)
type DMSAPICommand ¶
type DMSAPICommand string
const ( DefaultCommand DMSAPICommand = "DefaultCommand" DPUCapacityCommand DMSAPICommand = "DPUCapacityCommand" PCIRescanRequiredCommand DMSAPICommand = "PCIRescanRequired" CurrentFWVersionCommand DMSAPICommand = "CurrentFWVersion" RunningFWVersionCommand DMSAPICommand = "RunningFWVersion" HostNetworkConfigCommand DMSAPICommand = "HostNetworkConfig" HostNetworDeleteCommand DMSAPICommand = "HostNetworkDelete" )
type DMSServerMux ¶
type DMSServerMux struct {
*grpc.Server
ListenerManager
// contains filtered or unexported fields
}
func NewDMSServerMux ¶
func NewDMSServerMux(ip string, cert *x509.Certificate, key *rsa.PrivateKey, listenerManager ListenerManager, handler APIHandler) *DMSServerMux
func (*DMSServerMux) ServeForDPUNode ¶
func (d *DMSServerMux) ServeForDPUNode(dpuNode *provisioningv1.DPUNode, listener net.Listener) error
ServeForDPUNode creates allocates a port for a given DPU node and updates the DPUNode spec to point to the port.
type DPUNodeToPortListener ¶
type DPUNodeToPortListener struct {
sync.RWMutex
// MinPort is the highest port number the DMSServerMux can use when creating listeners.
MinPort uint16 // Minimum port number for use when creating listener instances.
// MaxPort is the highest port number the DMSServerMux can use when creating listeners.
MaxPort uint16
// contains filtered or unexported fields
}
func (*DPUNodeToPortListener) AllocateListener ¶
func (d *DPUNodeToPortListener) AllocateListener() (net.Listener, error)
type ListenerManager ¶
Click to show internal directories.
Click to hide internal directories.