server

package
v1.5.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 14, 2026 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// DefaultPort is the default port that the server listens at
	DefaultPort = ":11079"
	// DefaultVpcId is the default VPC ID for testing
	DefaultVpcId = "00000000-0000-4000-8000-000000000000"
	// DefaultNetworkSegmentId is the default NetworkSegment ID for testing
	DefaultNetworkSegmentId = "00000000-0000-4000-9000-000000000000"
	// DefaultTenantKeysetId is the default TenantKeyset ID for testing
	DefaultTenantKeysetId = "00000000-0000-4000-a000-000000000000"
	// DefaultIBParitionId is the default IBPartition ID for testing
	DefaultIBParitionId = "00000000-0000-4000-b000-000000000000"
)
View Source 
var (
	// FlowDefaultPort is the default port that the Flow server listens at
	FlowDefaultPort = ":11080"
)

Functions

func FlowTest 

func FlowTest(secs int)

FlowTest starts the Flow test gRPC server

func NICoTest 

func NICoTest(secs int)

NICoTest tests the grpc server

Types

type FlowServerImpl 

type FlowServerImpl struct {
	flowv1.UnimplementedFlowServer
	// contains filtered or unexported fields
}

FlowServerImpl implements interface FlowServer

func (*FlowServerImpl) AddComponent 

func (r *FlowServerImpl) AddComponent(ctx context.Context, req *flowv1.AddComponentRequest) (*flowv1.AddComponentResponse, error)

AddComponent implements interface FlowServer

func (*FlowServerImpl) AttachRacksToNVLDomain 

func (r *FlowServerImpl) AttachRacksToNVLDomain(ctx context.Context, req *flowv1.AttachRacksToNVLDomainRequest) (*emptypb.Empty, error)

AttachRacksToNVLDomain implements interface FlowServer

func (*FlowServerImpl) BringUpRack 

func (r *FlowServerImpl) BringUpRack(ctx context.Context, req *flowv1.BringUpRackRequest) (*flowv1.SubmitTaskResponse, error)

BringUpRack implements interface FlowServer

func (*FlowServerImpl) CreateExpectedRack 

func (r *FlowServerImpl) CreateExpectedRack(ctx context.Context, req *flowv1.CreateExpectedRackRequest) (*flowv1.CreateExpectedRackResponse, error)

CreateExpectedRack implements interface FlowServer

func (*FlowServerImpl) CreateNVLDomain 

func (r *FlowServerImpl) CreateNVLDomain(ctx context.Context, req *flowv1.CreateNVLDomainRequest) (*flowv1.CreateNVLDomainResponse, error)

CreateNVLDomain implements interface FlowServer

func (*FlowServerImpl) DeleteComponent 

func (r *FlowServerImpl) DeleteComponent(ctx context.Context, req *flowv1.DeleteComponentRequest) (*flowv1.DeleteComponentResponse, error)

DeleteComponent implements interface FlowServer

func (*FlowServerImpl) DetachRacksFromNVLDomain 

func (r *FlowServerImpl) DetachRacksFromNVLDomain(ctx context.Context, req *flowv1.DetachRacksFromNVLDomainRequest) (*emptypb.Empty, error)

DetachRacksFromNVLDomain implements interface FlowServer

func (*FlowServerImpl) GetComponentInfoByID 

func (r *FlowServerImpl) GetComponentInfoByID(ctx context.Context, req *flowv1.GetComponentInfoByIDRequest) (*flowv1.GetComponentInfoResponse, error)

GetComponentInfoByID implements interface FlowServer

func (*FlowServerImpl) GetComponentInfoBySerial 

func (r *FlowServerImpl) GetComponentInfoBySerial(ctx context.Context, req *flowv1.GetComponentInfoBySerialRequest) (*flowv1.GetComponentInfoResponse, error)

GetComponentInfoBySerial implements interface FlowServer

func (*FlowServerImpl) GetComponents 

func (r *FlowServerImpl) GetComponents(ctx context.Context, req *flowv1.GetComponentsRequest) (*flowv1.GetComponentsResponse, error)

GetComponents implements interface FlowServer

func (*FlowServerImpl) GetListOfNVLDomains 

func (r *FlowServerImpl) GetListOfNVLDomains(ctx context.Context, req *flowv1.GetListOfNVLDomainsRequest) (*flowv1.GetListOfNVLDomainsResponse, error)

GetListOfNVLDomains implements interface FlowServer

func (*FlowServerImpl) GetListOfRacks 

func (r *FlowServerImpl) GetListOfRacks(ctx context.Context, req *flowv1.GetListOfRacksRequest) (*flowv1.GetListOfRacksResponse, error)

GetListOfRacks implements interface FlowServer

func (*FlowServerImpl) GetRackInfoByID 

func (r *FlowServerImpl) GetRackInfoByID(ctx context.Context, req *flowv1.GetRackInfoByIDRequest) (*flowv1.GetRackInfoResponse, error)

GetRackInfoByID implements interface FlowServer

func (*FlowServerImpl) GetRackInfoBySerial 

func (r *FlowServerImpl) GetRackInfoBySerial(ctx context.Context, req *flowv1.GetRackInfoBySerialRequest) (*flowv1.GetRackInfoResponse, error)

GetRackInfoBySerial implements interface FlowServer

func (*FlowServerImpl) GetRacksForNVLDomain 

func (r *FlowServerImpl) GetRacksForNVLDomain(ctx context.Context, req *flowv1.GetRacksForNVLDomainRequest) (*flowv1.GetRacksForNVLDomainResponse, error)

GetRacksForNVLDomain implements interface FlowServer

func (*FlowServerImpl) GetTasksByIDs 

func (r *FlowServerImpl) GetTasksByIDs(ctx context.Context, req *flowv1.GetTasksByIDsRequest) (*flowv1.GetTasksByIDsResponse, error)

GetTasksByIDs implements interface FlowServer

func (*FlowServerImpl) ListTasks 

func (r *FlowServerImpl) ListTasks(ctx context.Context, req *flowv1.ListTasksRequest) (*flowv1.ListTasksResponse, error)

ListTasks implements interface FlowServer

func (*FlowServerImpl) PatchComponent 

func (r *FlowServerImpl) PatchComponent(ctx context.Context, req *flowv1.PatchComponentRequest) (*flowv1.PatchComponentResponse, error)

PatchComponent implements interface FlowServer

func (*FlowServerImpl) PatchRack 

func (r *FlowServerImpl) PatchRack(ctx context.Context, req *flowv1.PatchRackRequest) (*flowv1.PatchRackResponse, error)

PatchRack implements interface FlowServer

func (*FlowServerImpl) PowerOffRack 

func (r *FlowServerImpl) PowerOffRack(ctx context.Context, req *flowv1.PowerOffRackRequest) (*flowv1.SubmitTaskResponse, error)

PowerOffRack implements interface FlowServer

func (*FlowServerImpl) PowerOnRack 

func (r *FlowServerImpl) PowerOnRack(ctx context.Context, req *flowv1.PowerOnRackRequest) (*flowv1.SubmitTaskResponse, error)

PowerOnRack implements interface FlowServer

func (*FlowServerImpl) PowerResetRack 

func (r *FlowServerImpl) PowerResetRack(ctx context.Context, req *flowv1.PowerResetRackRequest) (*flowv1.SubmitTaskResponse, error)

PowerResetRack implements interface FlowServer

func (*FlowServerImpl) UpgradeFirmware 

func (r *FlowServerImpl) UpgradeFirmware(ctx context.Context, req *flowv1.UpgradeFirmwareRequest) (*flowv1.SubmitTaskResponse, error)

UpgradeFirmware implements interface FlowServer

func (*FlowServerImpl) ValidateComponents 

func (r *FlowServerImpl) ValidateComponents(ctx context.Context, req *flowv1.ValidateComponentsRequest) (*flowv1.ValidateComponentsResponse, error)

ValidateComponents implements interface FlowServer

func (*FlowServerImpl) Version 

func (r *FlowServerImpl) Version(ctx context.Context, req *flowv1.VersionRequest) (*flowv1.BuildInfo, error)

Version implements interface FlowServer

type NICoServerImpl 

type NICoServerImpl struct {
	cwssaws.UnimplementedForgeServer
	// contains filtered or unexported fields
}

NICoServerImpl implements interface NICoServer

func (*NICoServerImpl) AddExpectedMachine 

func (f *NICoServerImpl) AddExpectedMachine(ctx context.Context, req *cwssaws.ExpectedMachine) (*emptypb.Empty, error)

AddExpectedMachine implements interface NICoServer

func (*NICoServerImpl) AddExpectedPowerShelf 

func (f *NICoServerImpl) AddExpectedPowerShelf(ctx context.Context, req *cwssaws.ExpectedPowerShelf) (*emptypb.Empty, error)

AddExpectedPowerShelf implements interface NICoServer

func (*NICoServerImpl) AddExpectedRack 

func (f *NICoServerImpl) AddExpectedRack(ctx context.Context, req *cwssaws.ExpectedRack) (*emptypb.Empty, error)

AddExpectedRack implements interface NICoServer

func (*NICoServerImpl) AddExpectedSwitch 

func (f *NICoServerImpl) AddExpectedSwitch(ctx context.Context, req *cwssaws.ExpectedSwitch) (*emptypb.Empty, error)

AddExpectedSwitch implements interface NICoServer

func (*NICoServerImpl) AllocateInstance 

func (f *NICoServerImpl) AllocateInstance(ctx context.Context, req *cwssaws.InstanceAllocationRequest) (*cwssaws.Instance, error)

CreateInstance implements interface NICoServer

func (*NICoServerImpl) CreateExpectedMachines 

func (f *NICoServerImpl) CreateExpectedMachines(ctx context.Context, req *cwssaws.BatchExpectedMachineOperationRequest) (*cwssaws.BatchExpectedMachineOperationResponse, error)

CreateExpectedMachines implements interface NICoServer

func (*NICoServerImpl) CreateIBPartition 

func (f *NICoServerImpl) CreateIBPartition(c context.Context, req *cwssaws.IBPartitionCreationRequest) (*cwssaws.IBPartition, error)

CreateIBPartition implements interface NICoServer

func (*NICoServerImpl) CreateNetworkSegment 

func (f *NICoServerImpl) CreateNetworkSegment(c context.Context, req *cwssaws.NetworkSegmentCreationRequest) (*cwssaws.NetworkSegment, error)

CreateNetworkSegment implements interface NICoServer

func (*NICoServerImpl) CreateTenantKeyset 

func (f *NICoServerImpl) CreateTenantKeyset(c context.Context, req *cwssaws.CreateTenantKeysetRequest) (*cwssaws.CreateTenantKeysetResponse, error)

CreateTenantKeyset implements interface NICoServer

func (*NICoServerImpl) CreateVpc 

func (f *NICoServerImpl) CreateVpc(c context.Context, req *cwssaws.VpcCreationRequest) (*cwssaws.Vpc, error)

CreateVpc implements interface NICoServer

func (*NICoServerImpl) DeleteAllExpectedRacks 

func (f *NICoServerImpl) DeleteAllExpectedRacks(ctx context.Context, req *emptypb.Empty) (*emptypb.Empty, error)

DeleteAllExpectedRacks implements interface NICoServer

func (*NICoServerImpl) DeleteExpectedMachine 

func (f *NICoServerImpl) DeleteExpectedMachine(ctx context.Context, req *cwssaws.ExpectedMachineRequest) (*emptypb.Empty, error)

DeleteExpectedMachine implements interface NICoServer

func (*NICoServerImpl) DeleteExpectedPowerShelf 

func (f *NICoServerImpl) DeleteExpectedPowerShelf(ctx context.Context, req *cwssaws.ExpectedPowerShelfRequest) (*emptypb.Empty, error)

DeleteExpectedPowerShelf implements interface NICoServer

func (*NICoServerImpl) DeleteExpectedRack 

func (f *NICoServerImpl) DeleteExpectedRack(ctx context.Context, req *cwssaws.ExpectedRackRequest) (*emptypb.Empty, error)

DeleteExpectedRack implements interface NICoServer

func (*NICoServerImpl) DeleteExpectedSwitch 

func (f *NICoServerImpl) DeleteExpectedSwitch(ctx context.Context, req *cwssaws.ExpectedSwitchRequest) (*emptypb.Empty, error)

DeleteExpectedSwitch implements interface NICoServer

func (*NICoServerImpl) DeleteIBPartition 

func (f *NICoServerImpl) DeleteIBPartition(c context.Context, req *cwssaws.IBPartitionDeletionRequest) (*cwssaws.IBPartitionDeletionResult, error)

DeleteIBPartition implements interface NICoServer

func (*NICoServerImpl) DeleteNetworkSegment 

func (f *NICoServerImpl) DeleteNetworkSegment(c context.Context, req *cwssaws.NetworkSegmentDeletionRequest) (*cwssaws.NetworkSegmentDeletionResult, error)

DeleteNetworkSegment implements interface NICoServer

func (*NICoServerImpl) DeleteTenantKeyset 

func (f *NICoServerImpl) DeleteTenantKeyset(c context.Context, req *cwssaws.DeleteTenantKeysetRequest) (*cwssaws.DeleteTenantKeysetResponse, error)

DeleteTenantKeyset implements interface NICoServer

func (*NICoServerImpl) DeleteVpc 

func (f *NICoServerImpl) DeleteVpc(c context.Context, req *cwssaws.VpcDeletionRequest) (*cwssaws.VpcDeletionResult, error)

DeleteVpc implements interface NICoServer

func (*NICoServerImpl) FindIBPartitionIds 

func (f *NICoServerImpl) FindIBPartitionIds(ctx context.Context, req *cwssaws.IBPartitionSearchFilter) (*cwssaws.IBPartitionIdList, error)

FindIBPartitionIds implements interface NICoServer

func (*NICoServerImpl) FindIBPartitionsByIds 

func (f *NICoServerImpl) FindIBPartitionsByIds(ctx context.Context, req *cwssaws.IBPartitionsByIdsRequest) (*cwssaws.IBPartitionList, error)

FindIBPartitionsByIds implements interface NICoServer

func (*NICoServerImpl) FindInstanceIds 

func (f *NICoServerImpl) FindInstanceIds(ctx context.Context, req *cwssaws.InstanceSearchFilter) (*cwssaws.InstanceIdList, error)

FindInstances implements interface NICoServer

func (*NICoServerImpl) FindInstancesByIds 

func (f *NICoServerImpl) FindInstancesByIds(ctx context.Context, req *cwssaws.InstancesByIdsRequest) (*cwssaws.InstanceList, error)

FindInstances implements interface NICoServer

func (*NICoServerImpl) FindMachineIds 

func (f *NICoServerImpl) FindMachineIds(ctx context.Context, req *cwssaws.MachineSearchConfig) (*cwssaws.MachineIdList, error)

func (*NICoServerImpl) FindNetworkSegmentIds 

func (f *NICoServerImpl) FindNetworkSegmentIds(ctx context.Context, req *cwssaws.NetworkSegmentSearchFilter) (*cwssaws.NetworkSegmentIdList, error)

FindNetworkSegmentIds implements interface NICoServer

func (*NICoServerImpl) FindNetworkSegmentsByIds 

func (f *NICoServerImpl) FindNetworkSegmentsByIds(ctx context.Context, req *cwssaws.NetworkSegmentsByIdsRequest) (*cwssaws.NetworkSegmentList, error)

FindNetworkSegmentsByIds implements interface NICoServer

func (*NICoServerImpl) FindTenantKeysetIds 

func (f *NICoServerImpl) FindTenantKeysetIds(ctx context.Context, req *cwssaws.TenantKeysetSearchFilter) (*cwssaws.TenantKeysetIdList, error)

FindTenantKeysetIds implements interface NICoServer

func (*NICoServerImpl) FindTenantKeysetsByIds 

func (f *NICoServerImpl) FindTenantKeysetsByIds(ctx context.Context, req *cwssaws.TenantKeysetsByIdsRequest) (*cwssaws.TenantKeySetList, error)

FindTenantKeysetsByIds implements interface NICoServer

func (*NICoServerImpl) FindVpcIds 

func (f *NICoServerImpl) FindVpcIds(ctx context.Context, req *cwssaws.VpcSearchFilter) (*cwssaws.VpcIdList, error)

FindVpcIds implements interface NICoServer

func (*NICoServerImpl) FindVpcs 

func (f *NICoServerImpl) FindVpcs(c context.Context, req *cwssaws.VpcSearchQuery) (*cwssaws.VpcList, error)

FindVpcs implements interface NICoServer

func (*NICoServerImpl) FindVpcsByIds 

func (f *NICoServerImpl) FindVpcsByIds(ctx context.Context, req *cwssaws.VpcsByIdsRequest) (*cwssaws.VpcList, error)

FindVpcsByIds implements interface NICoServer

func (*NICoServerImpl) GetAllExpectedPowerShelves 

func (f *NICoServerImpl) GetAllExpectedPowerShelves(ctx context.Context, req *emptypb.Empty) (*cwssaws.ExpectedPowerShelfList, error)

GetAllExpectedPowerShelves implements interface NICoServer

func (*NICoServerImpl) GetAllExpectedRacks 

func (f *NICoServerImpl) GetAllExpectedRacks(ctx context.Context, req *emptypb.Empty) (*cwssaws.ExpectedRackList, error)

GetAllExpectedRacks implements interface NICoServer

func (*NICoServerImpl) GetAllExpectedSwitches 

func (f *NICoServerImpl) GetAllExpectedSwitches(ctx context.Context, req *emptypb.Empty) (*cwssaws.ExpectedSwitchList, error)

GetAllExpectedSwitches implements interface NICoServer

func (*NICoServerImpl) GetExpectedPowerShelf 

func (f *NICoServerImpl) GetExpectedPowerShelf(ctx context.Context, req *cwssaws.ExpectedPowerShelfRequest) (*cwssaws.ExpectedPowerShelf, error)

GetExpectedPowerShelf implements interface NICoServer

func (*NICoServerImpl) GetExpectedRack 

func (f *NICoServerImpl) GetExpectedRack(ctx context.Context, req *cwssaws.ExpectedRackRequest) (*cwssaws.ExpectedRack, error)

GetExpectedRack implements interface NICoServer

func (*NICoServerImpl) GetExpectedSwitch 

func (f *NICoServerImpl) GetExpectedSwitch(ctx context.Context, req *cwssaws.ExpectedSwitchRequest) (*cwssaws.ExpectedSwitch, error)

GetExpectedSwitch implements interface NICoServer

func (*NICoServerImpl) InvokeInstancePower 

func (f *NICoServerImpl) InvokeInstancePower(c context.Context, req *cwssaws.InstancePowerRequest) (*cwssaws.InstancePowerResult, error)

InvokeInstancePower implements interface NICoServer

func (*NICoServerImpl) LoadTestMachines 

func (f *NICoServerImpl) LoadTestMachines()

LoadTestMachines loads test machines into the server

func (*NICoServerImpl) ReleaseInstance 

func (f *NICoServerImpl) ReleaseInstance(c context.Context, req *cwssaws.InstanceReleaseRequest) (*cwssaws.InstanceReleaseResult, error)

DeleteInstance implements interface NICoServer

func (*NICoServerImpl) ReplaceAllExpectedRacks 

func (f *NICoServerImpl) ReplaceAllExpectedRacks(ctx context.Context, req *cwssaws.ExpectedRackList) (*emptypb.Empty, error)

ReplaceAllExpectedRacks implements interface NICoServer

func (*NICoServerImpl) SetMaintenance 

func (f *NICoServerImpl) SetMaintenance(context.Context, *cwssaws.MaintenanceRequest) (*emptypb.Empty, error)

func (*NICoServerImpl) UpdateExpectedMachine 

func (f *NICoServerImpl) UpdateExpectedMachine(ctx context.Context, req *cwssaws.ExpectedMachine) (*emptypb.Empty, error)

UpdateExpectedMachine implements interface NICoServer

func (*NICoServerImpl) UpdateExpectedMachines 

func (f *NICoServerImpl) UpdateExpectedMachines(ctx context.Context, req *cwssaws.BatchExpectedMachineOperationRequest) (*cwssaws.BatchExpectedMachineOperationResponse, error)

UpdateExpectedMachines implements interface NICoServer

func (*NICoServerImpl) UpdateExpectedPowerShelf 

func (f *NICoServerImpl) UpdateExpectedPowerShelf(ctx context.Context, req *cwssaws.ExpectedPowerShelf) (*emptypb.Empty, error)

UpdateExpectedPowerShelf implements interface NICoServer

func (*NICoServerImpl) UpdateExpectedRack 

func (f *NICoServerImpl) UpdateExpectedRack(ctx context.Context, req *cwssaws.ExpectedRack) (*emptypb.Empty, error)

UpdateExpectedRack implements interface NICoServer

func (*NICoServerImpl) UpdateExpectedSwitch 

func (f *NICoServerImpl) UpdateExpectedSwitch(ctx context.Context, req *cwssaws.ExpectedSwitch) (*emptypb.Empty, error)

UpdateExpectedSwitch implements interface NICoServer

func (*NICoServerImpl) UpdateIBPartition 

func (f *NICoServerImpl) UpdateIBPartition(c context.Context, req *cwssaws.IBPartitionUpdateRequest) (*cwssaws.IBPartition, error)

UpdateIBPartition implements interface NICoServer

func (*NICoServerImpl) UpdateTenantKeyset 

func (f *NICoServerImpl) UpdateTenantKeyset(c context.Context, req *cwssaws.UpdateTenantKeysetRequest) (*cwssaws.UpdateTenantKeysetResponse, error)

UpdateTenantKeyset implements interface NICoServer

func (*NICoServerImpl) UpdateVpc 

func (f *NICoServerImpl) UpdateVpc(c context.Context, req *cwssaws.VpcUpdateRequest) (*cwssaws.VpcUpdateResult, error)

UpdateVpc implements interface NICoServer

func (*NICoServerImpl) Version 

func (f *NICoServerImpl) Version(ctx context.Context, req *cwssaws.VersionRequest) (*cwssaws.BuildInfo, error)

Version implements interface NICoServer

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.