client

package
v1.6.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	// InsecureGrpc is the insecure dial option
	InsecureGrpc SecureOptions = iota
	// ServerTLS is the secure dial option for server tls
	ServerTLS
	// MutualTLS for mutual tls
	MutualTLS

	// CoreGrpcConnectionRetryTimeout is the maximum time to retry establishing a Core gRPC connection.
	CoreGrpcConnectionRetryTimeout = 15 * time.Minute
	// CoreGrpcConnectionBackoffInitial is the initial delay between connection retries.
	CoreGrpcConnectionBackoffInitial = 5 * time.Second
	// CoreGrpcConnectionBackoffMax is the maximum delay between connection retries.
	CoreGrpcConnectionBackoffMax = 60 * time.Second
)
View Source 
const (
	// FlowInsecureGrpc is the insecure dial option
	FlowInsecureGrpc FlowGrpcClientSecureOptions = iota
	// FlowServerTLS is the secure dial option for server tls
	FlowServerTLS
	// FlowMutualTLS for mutual tls
	FlowMutualTLS

	// FlowGrpcConnectionRetryTimeout is the maximum time to retry establishing a Flow gRPC connection.
	FlowGrpcConnectionRetryTimeout = 15 * time.Minute
	// FlowGrpcConnectionBackoffInitial is the initial delay between connection retries.
	FlowGrpcConnectionBackoffInitial = 5 * time.Second
	// FlowGrpcConnectionBackoffMax is the maximum delay between connection retries.
	FlowGrpcConnectionBackoffMax = 60 * time.Second
)

Variables

View Source 
var (
	ErrCoreGrpcClientInvalidAddress    = errors.New("CoreGrpcClient: invalid address")
	ErrCoreGrpcClientInvalidDialOpts   = errors.New("CoreGrpcClient: invalid dial options")
	ErrCoreGrpcClientInvalidSecureOpts = errors.New("CoreGrpcClient: invalid secure options")
	ErrCoreGrpcClientInvalidServerCA   = errors.New("CoreGrpcClient: invalid server CA")
	ErrCoreGrpcClientInvalidClientCA   = errors.New("CoreGrpcClient: invalid client CA")
	ErrCoreGrpcClientInvalidClientKey  = errors.New("CoreGrpcClient: invalid client key")
	ErrCoreGrpcClientInvalidClientCert = errors.New("CoreGrpcClient: invalid client cert")
	ErrCoreGrpcClientNotConnected      = errors.New("CoreGrpcClient: gRPC client is not connected to the server")
)

Errors

View Source 
var (
	ErrFlowGrpcClientInvalidAddress    = errors.New("FlowGrpcClient: invalid address")
	ErrFlowGrpcClientInvalidDialOpts   = errors.New("FlowGrpcClient: invalid dial options")
	ErrFlowGrpcClientInvalidSecureOpts = errors.New("FlowGrpcClient: invalid secure options")
	ErrFlowGrpcClientInvalidServerCA   = errors.New("FlowGrpcClient: invalid server CA")
	ErrFlowGrpcClientInvalidClientCA   = errors.New("FlowGrpcClient: invalid client CA")
	ErrFlowGrpcClientInvalidClientKey  = errors.New("FlowGrpcClient: invalid client key")
	ErrFlowGrpcClientInvalidClientCert = errors.New("FlowGrpcClient: invalid client cert")
	ErrFlowGrpcClientNotConnected      = errors.New("FlowGrpcClient: gRPC client is not connected to the server")
)

Errors

Functions

func SliceToChunks 

func SliceToChunks[T any](slice []T, chunkSize int) (chunks [][]T)

Types

type CoreGrpcAtomicClient added in v1.6.0 

type CoreGrpcAtomicClient struct {
	Config *CoreGrpcClientConfig
	// contains filtered or unexported fields
}

CoreGrpcAtomicClient is an atomic wrapper around the CoreGrpcClient

func NewCoreGrpcAtomicClient added in v1.6.0 

func NewCoreGrpcAtomicClient(config *CoreGrpcClientConfig) *CoreGrpcAtomicClient

NewCoreGrpcAtomicClient creates a new CoreGrpcAtomicClient

func (*CoreGrpcAtomicClient) CheckAndReloadCerts added in v1.6.0 

func (cac *CoreGrpcAtomicClient) CheckAndReloadCerts(initialClientCertMD5, initialServerCAMD5 []byte)

CheckAndReloadCerts continuously monitors the TLS certificates for changes. If a change is detected, it reinitializes the CoreGrpcClient with the new certificates to ensure secure communication.

func (*CoreGrpcAtomicClient) CheckCertificates added in v1.6.0 

func (cac *CoreGrpcAtomicClient) CheckCertificates(lastClientCertMD5, lastServerCAMD5 []byte) (bool, []byte, []byte, error)

CheckCertificates checks if the client and server CA certificates have changed

func (*CoreGrpcAtomicClient) GetClient added in v1.6.0 

func (cac *CoreGrpcAtomicClient) GetClient() *CoreGrpcClient

GetClient returns the current version of CoreGrpcClient from the atomic value. Returns nil if the client has not been initialized yet.

func (*CoreGrpcAtomicClient) GetInitialCertMD5 added in v1.6.0 

func (cac *CoreGrpcAtomicClient) GetInitialCertMD5() (clientCertMD5, serverCAMD5 []byte, err error)

GetInitialCertMD5 retrieves the MD5 hash of the initial set of certificate that the client is Using

func (*CoreGrpcAtomicClient) SwapClient added in v1.6.0 

func (cac *CoreGrpcAtomicClient) SwapClient(newClient *CoreGrpcClient) *CoreGrpcClient

SwapClient atomically replaces the current CoreGrpcClient with a new one, returning the old client for the caller to manage.

func (*CoreGrpcAtomicClient) Version added in v1.6.0 

func (cac *CoreGrpcAtomicClient) Version() int64

Version returns the current version of the CoreGrpcClient

type CoreGrpcClient added in v1.6.0 

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

CoreGrpcClient is the data structure for the client

func NewCoreGrpcClient added in v1.6.0 

func NewCoreGrpcClient(config *CoreGrpcClientConfig) (client *CoreGrpcClient, err error)

NewCoreGrpcClient creates a new Core gRPC client, this is called by Site Agent startup code and cert reload routine Caller is responsible for retrying connection failure

func NewMockCoreGrpcClient added in v1.6.0 

func NewMockCoreGrpcClient() *CoreGrpcClient

NewMockCoreGrpcClient creates a new mock CoreGrpcClient

func (*CoreGrpcClient) Close added in v1.6.0 

func (cc *CoreGrpcClient) Close() error

Close gracefully shuts down the client's gRPC connection.

func (*CoreGrpcClient) GrpcServiceClient added in v1.6.0 

func (client *CoreGrpcClient) GrpcServiceClient() wflows.ForgeClient

GrpcServiceClient client getter

type CoreGrpcClientConfig added in v1.6.0 

type CoreGrpcClientConfig struct {
	// The address of the server <host>:<port>
	Address string
	// Secure flag
	Secure SecureOptions
	// Skip Server Auth
	SkipServerAuth bool
	// The TLS certificate for the server
	ServerCAPath string
	// The TLS certificate for the client
	ClientCertPath string
	// The TLS key for the client
	ClientKeyPath string
	// client metrics interface
	ClientMetrics Metrics
}

CoreGrpcClientConfig is the data structure for the client configuration

type FlowGrpcAtomicClient added in v1.6.0 

type FlowGrpcAtomicClient struct {
	Config *FlowGrpcClientConfig
	// contains filtered or unexported fields
}

FlowAtomicClient is an atomic wrapper around the FlowClient

func NewFlowGrpcAtomicClient added in v1.6.0 

func NewFlowGrpcAtomicClient(config *FlowGrpcClientConfig) *FlowGrpcAtomicClient

NewFlowAtomicClient creates a new FlowAtomicClient

func (*FlowGrpcAtomicClient) CheckAndReloadCerts added in v1.6.0 

func (fgac *FlowGrpcAtomicClient) CheckAndReloadCerts(initialClientCertMD5, initialServerCAMD5 []byte)

CheckAndReloadCerts continuously monitors the TLS certificates for changes. If a change is detected, it reinitializes the FlowGrpcClient with the new certificates to ensure secure communication.

func (*FlowGrpcAtomicClient) CheckCertificates added in v1.6.0 

func (fgac *FlowGrpcAtomicClient) CheckCertificates(lastClientCertMD5, lastServerCAMD5 []byte) (bool, []byte, []byte, error)

CheckCertificates checks if the client and server CA certificates have changed

func (*FlowGrpcAtomicClient) GetClient added in v1.6.0 

func (fgac *FlowGrpcAtomicClient) GetClient() *FlowGrpcClient

GetClient returns the current version of FlowGrpcClient from the atomic value. Returns nil if the client has not been initialized yet.

func (*FlowGrpcAtomicClient) GetInitialCertMD5 added in v1.6.0 

func (fgac *FlowGrpcAtomicClient) GetInitialCertMD5() (clientCertMD5, serverCAMD5 []byte, err error)

GetInitialCertMD5 retrieves the MD5 hash of the initial set of certificate that the client is Using

func (*FlowGrpcAtomicClient) GrpcServiceClient added in v1.6.0 

func (fgac *FlowGrpcAtomicClient) GrpcServiceClient() (flowv1.FlowClient, error)

GrpcServiceClient returns the underlying Flow gRPC service. Returns ErrFlowGrpcClientNotConnected if the client has not been initialized or is not currently connected. Prefer this over GetClient() + manual nil-check + .GrpcServiceClient() at call sites.

func (*FlowGrpcAtomicClient) SwapClient added in v1.6.0 

func (fgac *FlowGrpcAtomicClient) SwapClient(newClient *FlowGrpcClient) *FlowGrpcClient

SwapClient atomically replaces the current FlowGrpcClient with a new one, returning the old client for the caller to manage.

func (*FlowGrpcAtomicClient) Version added in v1.6.0 

func (fgac *FlowGrpcAtomicClient) Version() int64

Version returns the current version of the FlowGrpcClient

type FlowGrpcClient added in v1.6.0 

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

FlowGrpcClient is the data structure for the client

func NewFlowGrpcClient added in v1.6.0 

func NewFlowGrpcClient(config *FlowGrpcClientConfig) (client *FlowGrpcClient, err error)

NewFlowGrpcClient creates a new Flow gRPC client, this is called by Site Agent startup code and cert reload routine Caller is responsible for retrying connection failure

func NewMockFlowGrpcClient added in v1.6.0 

func NewMockFlowGrpcClient() *FlowGrpcClient

NewMockFlowClient creates a new mock FlowClient that can be used with FlowAtomicClient.SwapClient

func (*FlowGrpcClient) Close added in v1.6.0 

func (fg *FlowGrpcClient) Close() error

Close gracefully shuts down the client's gRPC connection.

func (*FlowGrpcClient) GrpcServiceClient added in v1.6.0 

func (client *FlowGrpcClient) GrpcServiceClient() flowv1.FlowClient

GrpcService client getter

type FlowGrpcClientConfig added in v1.6.0 

type FlowGrpcClientConfig struct {
	// The address of the server <host>:<port>
	Address string
	// Secure flag
	Secure FlowGrpcClientSecureOptions
	// Skip Server Auth
	SkipServerAuth bool
	// The TLS certificate for the server
	ServerCAPath string
	// The TLS certificate for the client
	ClientCertPath string
	// The TLS key for the client
	ClientKeyPath string
	// client metrics interface
	ClientMetrics Metrics
}

FlowClientConfig is the data structure for the client configuration

type FlowGrpcClientSecureOptions added in v1.6.0 

type FlowGrpcClientSecureOptions int

SecureOptions is the enum for the secure options

type Metrics 

type Metrics interface {
	// RecordRpcResponse call-back method that includes rpc method, response code, and duration
	RecordRpcResponse(method, code string, duration time.Duration)
}

Metrics interface that defines call-back functions for RPC metrics

type MockCoreGrpcServiceClient added in v1.6.0 

type MockCoreGrpcServiceClient struct {
	wflows.ForgeClient
}

MockCoreGrpcService is a mock implementation of Core gRPC protobuf Service

func (*MockCoreGrpcServiceClient) AddExpectedMachine added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) AddExpectedMachine(ctx context.Context, in *wflows.ExpectedMachine, opts ...grpc.CallOption) (*emptypb.Empty, error)

Expected Machine mock methods

func (*MockCoreGrpcServiceClient) AddExpectedPowerShelf added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) AddExpectedPowerShelf(ctx context.Context, in *wflows.ExpectedPowerShelf, opts ...grpc.CallOption) (*emptypb.Empty, error)

Expected Power Shelf mock methods

func (*MockCoreGrpcServiceClient) AddExpectedRack added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) AddExpectedRack(ctx context.Context, in *wflows.ExpectedRack, opts ...grpc.CallOption) (*emptypb.Empty, error)

Expected Rack mock methods

func (*MockCoreGrpcServiceClient) AddExpectedSwitch added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) AddExpectedSwitch(ctx context.Context, in *wflows.ExpectedSwitch, opts ...grpc.CallOption) (*emptypb.Empty, error)

Expected Switch mock methods

func (*MockCoreGrpcServiceClient) AddMachineValidationTest added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) AddMachineValidationTest(ctx context.Context, in *wflows.MachineValidationTestAddRequest, opts ...grpc.CallOption) (*wflows.MachineValidationTestAddUpdateResponse, error)

Machine Validation Test mock methods

func (*MockCoreGrpcServiceClient) AddUpdateMachineValidationExternalConfig added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) AddUpdateMachineValidationExternalConfig(ctx context.Context, in *wflows.AddUpdateMachineValidationExternalConfigRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) AllocateInstance added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) AllocateInstance(ctx context.Context, in *wflows.InstanceAllocationRequest, opts ...grpc.CallOption) (*wflows.Instance, error)

Instance mock methods

func (*MockCoreGrpcServiceClient) AllocateInstances added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) AllocateInstances(ctx context.Context, in *wflows.BatchInstanceAllocationRequest, opts ...grpc.CallOption) (*wflows.BatchInstanceAllocationResponse, error)

func (*MockCoreGrpcServiceClient) AssociateMachinesWithInstanceType added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) AssociateMachinesWithInstanceType(ctx context.Context, in *wflows.AssociateMachinesWithInstanceTypeRequest, opts ...grpc.CallOption) (*wflows.AssociateMachinesWithInstanceTypeResponse, error)

func (*MockCoreGrpcServiceClient) CreateDpuExtensionService added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) CreateDpuExtensionService(ctx context.Context, in *wflows.CreateDpuExtensionServiceRequest, opts ...grpc.CallOption) (*wflows.DpuExtensionService, error)

DPU Extension Service mock methods

func (*MockCoreGrpcServiceClient) CreateExpectedMachines added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) CreateExpectedMachines(ctx context.Context, in *wflows.BatchExpectedMachineOperationRequest, opts ...grpc.CallOption) (*wflows.BatchExpectedMachineOperationResponse, error)

func (*MockCoreGrpcServiceClient) CreateIBPartition added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) CreateIBPartition(ctx context.Context, in *wflows.IBPartitionCreationRequest, opts ...grpc.CallOption) (*wflows.IBPartition, error)

InfiniBand Partition mock methods

func (*MockCoreGrpcServiceClient) CreateInstanceType added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) CreateInstanceType(ctx context.Context, in *wflows.CreateInstanceTypeRequest, opts ...grpc.CallOption) (*wflows.CreateInstanceTypeResponse, error)

Instance Type mock methods

func (*MockCoreGrpcServiceClient) CreateNVLinkLogicalPartition added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) CreateNVLinkLogicalPartition(ctx context.Context, in *wflows.NVLinkLogicalPartitionCreationRequest, opts ...grpc.CallOption) (*wflows.NVLinkLogicalPartition, error)

NVLink Logical Partition Mocks

func (*MockCoreGrpcServiceClient) CreateNetworkSecurityGroup added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) CreateNetworkSecurityGroup(ctx context.Context, in *wflows.CreateNetworkSecurityGroupRequest, opts ...grpc.CallOption) (*wflows.CreateNetworkSecurityGroupResponse, error)

func (*MockCoreGrpcServiceClient) CreateNetworkSegment added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) CreateNetworkSegment(ctx context.Context, in *wflows.NetworkSegmentCreationRequest, opts ...grpc.CallOption) (*wflows.NetworkSegment, error)

func (*MockCoreGrpcServiceClient) CreateOsImage added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) CreateOsImage(ctx context.Context, in *wflows.OsImageAttributes, opts ...grpc.CallOption) (*wflows.OsImage, error)

OS Image mock methods

func (*MockCoreGrpcServiceClient) CreateTenant added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) CreateTenant(ctx context.Context, in *wflows.CreateTenantRequest, opts ...grpc.CallOption) (*wflows.CreateTenantResponse, error)

Tenant mock methods

func (*MockCoreGrpcServiceClient) CreateTenantKeyset added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) CreateTenantKeyset(ctx context.Context, in *wflows.CreateTenantKeysetRequest, opts ...grpc.CallOption) (*wflows.CreateTenantKeysetResponse, error)

Tenant Keyset mock methods

func (*MockCoreGrpcServiceClient) CreateVpc added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) CreateVpc(ctx context.Context, in *wflows.VpcCreationRequest, opts ...grpc.CallOption) (*wflows.Vpc, error)

VPC mock methods

func (*MockCoreGrpcServiceClient) CreateVpcPeering added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) CreateVpcPeering(ctx context.Context, in *wflows.VpcPeeringCreationRequest, opts ...grpc.CallOption) (*wflows.VpcPeering, error)

VPC Peering mock methods

func (*MockCoreGrpcServiceClient) CreateVpcPrefix added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) CreateVpcPrefix(ctx context.Context, in *wflows.VpcPrefixCreationRequest, opts ...grpc.CallOption) (*wflows.VpcPrefix, error)

VPC Prefix mock methods

func (*MockCoreGrpcServiceClient) DeleteAllExpectedRacks added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteAllExpectedRacks(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) DeleteDpuExtensionService added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteDpuExtensionService(ctx context.Context, in *wflows.DeleteDpuExtensionServiceRequest, opts ...grpc.CallOption) (*wflows.DeleteDpuExtensionServiceResponse, error)

func (*MockCoreGrpcServiceClient) DeleteExpectedMachine added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteExpectedMachine(ctx context.Context, in *wflows.ExpectedMachineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) DeleteExpectedPowerShelf added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteExpectedPowerShelf(ctx context.Context, in *wflows.ExpectedPowerShelfRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) DeleteExpectedRack added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteExpectedRack(ctx context.Context, in *wflows.ExpectedRackRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) DeleteExpectedSwitch added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteExpectedSwitch(ctx context.Context, in *wflows.ExpectedSwitchRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) DeleteIBPartition added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteIBPartition(ctx context.Context, in *wflows.IBPartitionDeletionRequest, opts ...grpc.CallOption) (*wflows.IBPartitionDeletionResult, error)

func (*MockCoreGrpcServiceClient) DeleteInstanceType added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteInstanceType(ctx context.Context, in *wflows.DeleteInstanceTypeRequest, opts ...grpc.CallOption) (*wflows.DeleteInstanceTypeResponse, error)

func (*MockCoreGrpcServiceClient) DeleteNVLinkLogicalPartition added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteNVLinkLogicalPartition(ctx context.Context, in *wflows.NVLinkLogicalPartitionDeletionRequest, opts ...grpc.CallOption) (*wflows.NVLinkLogicalPartitionDeletionResult, error)

func (*MockCoreGrpcServiceClient) DeleteNetworkSecurityGroup added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteNetworkSecurityGroup(ctx context.Context, in *wflows.DeleteNetworkSecurityGroupRequest, opts ...grpc.CallOption) (*wflows.DeleteNetworkSecurityGroupResponse, error)

func (*MockCoreGrpcServiceClient) DeleteNetworkSegment added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteNetworkSegment(ctx context.Context, in *wflows.NetworkSegmentDeletionRequest, opts ...grpc.CallOption) (*wflows.NetworkSegmentDeletionResult, error)

func (*MockCoreGrpcServiceClient) DeleteOsImage added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteOsImage(ctx context.Context, in *wflows.DeleteOsImageRequest, opts ...grpc.CallOption) (*wflows.DeleteOsImageResponse, error)

func (*MockCoreGrpcServiceClient) DeleteTenantKeyset added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteTenantKeyset(ctx context.Context, in *wflows.DeleteTenantKeysetRequest, opts ...grpc.CallOption) (*wflows.DeleteTenantKeysetResponse, error)

func (*MockCoreGrpcServiceClient) DeleteVpc added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteVpc(ctx context.Context, in *wflows.VpcDeletionRequest, opts ...grpc.CallOption) (*wflows.VpcDeletionResult, error)

func (*MockCoreGrpcServiceClient) DeleteVpcPeering added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteVpcPeering(ctx context.Context, in *wflows.VpcPeeringDeletionRequest, opts ...grpc.CallOption) (*wflows.VpcPeeringDeletionResult, error)

func (*MockCoreGrpcServiceClient) DeleteVpcPrefix added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) DeleteVpcPrefix(ctx context.Context, in *wflows.VpcPrefixDeletionRequest, opts ...grpc.CallOption) (*wflows.VpcPrefixDeletionResult, error)

func (*MockCoreGrpcServiceClient) FindDpuExtensionServiceIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindDpuExtensionServiceIds(ctx context.Context, in *wflows.DpuExtensionServiceSearchFilter, opts ...grpc.CallOption) (*wflows.DpuExtensionServiceIdList, error)

func (*MockCoreGrpcServiceClient) FindDpuExtensionServicesByIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindDpuExtensionServicesByIds(ctx context.Context, in *wflows.DpuExtensionServicesByIdsRequest, opts ...grpc.CallOption) (*wflows.DpuExtensionServiceList, error)

func (*MockCoreGrpcServiceClient) FindIBPartitionIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindIBPartitionIds(ctx context.Context, in *wflows.IBPartitionSearchFilter, opts ...grpc.CallOption) (*wflows.IBPartitionIdList, error)

func (*MockCoreGrpcServiceClient) FindIBPartitionsByIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindIBPartitionsByIds(ctx context.Context, in *wflows.IBPartitionsByIdsRequest, opts ...grpc.CallOption) (*wflows.IBPartitionList, error)

func (*MockCoreGrpcServiceClient) FindInstanceIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindInstanceIds(ctx context.Context, in *wflows.InstanceSearchFilter, opts ...grpc.CallOption) (*wflows.InstanceIdList, error)

func (*MockCoreGrpcServiceClient) FindInstanceTypeIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindInstanceTypeIds(ctx context.Context, in *wflows.FindInstanceTypeIdsRequest, opts ...grpc.CallOption) (*wflows.FindInstanceTypeIdsResponse, error)

func (*MockCoreGrpcServiceClient) FindInstanceTypesByIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindInstanceTypesByIds(ctx context.Context, in *wflows.FindInstanceTypesByIdsRequest, opts ...grpc.CallOption) (*wflows.FindInstanceTypesByIdsResponse, error)

func (*MockCoreGrpcServiceClient) FindInstancesByIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindInstancesByIds(ctx context.Context, in *wflows.InstancesByIdsRequest, opts ...grpc.CallOption) (*wflows.InstanceList, error)

func (*MockCoreGrpcServiceClient) FindMachineIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindMachineIds(ctx context.Context, in *wflows.MachineSearchConfig, opts ...grpc.CallOption) (*wflows.MachineIdList, error)

func (*MockCoreGrpcServiceClient) FindMachinesByIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindMachinesByIds(ctx context.Context, in *wflows.MachinesByIdsRequest, opts ...grpc.CallOption) (*wflows.MachineList, error)

func (*MockCoreGrpcServiceClient) FindNVLinkLogicalPartitionIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindNVLinkLogicalPartitionIds(ctx context.Context, in *wflows.NVLinkLogicalPartitionSearchFilter, opts ...grpc.CallOption) (*wflows.NVLinkLogicalPartitionIdList, error)

func (*MockCoreGrpcServiceClient) FindNVLinkLogicalPartitionsByIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindNVLinkLogicalPartitionsByIds(ctx context.Context, in *wflows.NVLinkLogicalPartitionsByIdsRequest, opts ...grpc.CallOption) (*wflows.NVLinkLogicalPartitionList, error)

func (*MockCoreGrpcServiceClient) FindNetworkSecurityGroupIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindNetworkSecurityGroupIds(ctx context.Context, in *wflows.FindNetworkSecurityGroupIdsRequest, opts ...grpc.CallOption) (*wflows.FindNetworkSecurityGroupIdsResponse, error)

func (*MockCoreGrpcServiceClient) FindNetworkSecurityGroupsByIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindNetworkSecurityGroupsByIds(ctx context.Context, in *wflows.FindNetworkSecurityGroupsByIdsRequest, opts ...grpc.CallOption) (*wflows.FindNetworkSecurityGroupsByIdsResponse, error)

func (*MockCoreGrpcServiceClient) FindNetworkSegmentIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindNetworkSegmentIds(ctx context.Context, in *wflows.NetworkSegmentSearchFilter, opts ...grpc.CallOption) (*wflows.NetworkSegmentIdList, error)

func (*MockCoreGrpcServiceClient) FindNetworkSegmentsByIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindNetworkSegmentsByIds(ctx context.Context, in *wflows.NetworkSegmentsByIdsRequest, opts ...grpc.CallOption) (*wflows.NetworkSegmentList, error)

func (*MockCoreGrpcServiceClient) FindSkusByIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindSkusByIds(ctx context.Context, in *wflows.SkusByIdsRequest, opts ...grpc.CallOption) (*wflows.SkuList, error)

SKU mock methods

func (*MockCoreGrpcServiceClient) FindTenant added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindTenant(ctx context.Context, in *wflows.FindTenantRequest, opts ...grpc.CallOption) (*wflows.FindTenantResponse, error)

func (*MockCoreGrpcServiceClient) FindTenantKeysetIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindTenantKeysetIds(ctx context.Context, in *wflows.TenantKeysetSearchFilter, opts ...grpc.CallOption) (*wflows.TenantKeysetIdList, error)

func (*MockCoreGrpcServiceClient) FindTenantKeysetsByIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindTenantKeysetsByIds(ctx context.Context, in *wflows.TenantKeysetsByIdsRequest, opts ...grpc.CallOption) (*wflows.TenantKeySetList, error)

func (*MockCoreGrpcServiceClient) FindTenantOrganizationIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindTenantOrganizationIds(ctx context.Context, in *wflows.TenantSearchFilter, opts ...grpc.CallOption) (*wflows.TenantOrganizationIdList, error)

func (*MockCoreGrpcServiceClient) FindTenantsByOrganizationIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindTenantsByOrganizationIds(ctx context.Context, in *wflows.TenantByOrganizationIdsRequest, opts ...grpc.CallOption) (*wflows.TenantList, error)

func (*MockCoreGrpcServiceClient) FindVpcIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindVpcIds(ctx context.Context, in *wflows.VpcSearchFilter, opts ...grpc.CallOption) (*wflows.VpcIdList, error)

func (*MockCoreGrpcServiceClient) FindVpcPeeringIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindVpcPeeringIds(ctx context.Context, in *wflows.VpcPeeringSearchFilter, opts ...grpc.CallOption) (*wflows.VpcPeeringIdList, error)

func (*MockCoreGrpcServiceClient) FindVpcPeeringsByIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindVpcPeeringsByIds(ctx context.Context, in *wflows.VpcPeeringsByIdsRequest, opts ...grpc.CallOption) (*wflows.VpcPeeringList, error)

func (*MockCoreGrpcServiceClient) FindVpcsByIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) FindVpcsByIds(ctx context.Context, in *wflows.VpcsByIdsRequest, opts ...grpc.CallOption) (*wflows.VpcList, error)

func (*MockCoreGrpcServiceClient) GetAllExpectedMachines added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetAllExpectedMachines(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*wflows.ExpectedMachineList, error)

func (*MockCoreGrpcServiceClient) GetAllExpectedMachinesLinked added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetAllExpectedMachinesLinked(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*wflows.LinkedExpectedMachineList, error)

func (*MockCoreGrpcServiceClient) GetAllExpectedPowerShelves added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetAllExpectedPowerShelves(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*wflows.ExpectedPowerShelfList, error)

func (*MockCoreGrpcServiceClient) GetAllExpectedPowerShelvesLinked added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetAllExpectedPowerShelvesLinked(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*wflows.LinkedExpectedPowerShelfList, error)

func (*MockCoreGrpcServiceClient) GetAllExpectedRacks added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetAllExpectedRacks(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*wflows.ExpectedRackList, error)

func (*MockCoreGrpcServiceClient) GetAllExpectedSwitches added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetAllExpectedSwitches(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*wflows.ExpectedSwitchList, error)

func (*MockCoreGrpcServiceClient) GetAllExpectedSwitchesLinked added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetAllExpectedSwitchesLinked(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*wflows.LinkedExpectedSwitchList, error)

func (*MockCoreGrpcServiceClient) GetAllSkuIds added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetAllSkuIds(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*wflows.SkuIdList, error)

func (*MockCoreGrpcServiceClient) GetDpuExtensionServiceVersionsInfo added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetDpuExtensionServiceVersionsInfo(ctx context.Context, in *wflows.GetDpuExtensionServiceVersionsInfoRequest, opts ...grpc.CallOption) (*wflows.DpuExtensionServiceVersionInfoList, error)

func (*MockCoreGrpcServiceClient) GetExpectedMachine added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetExpectedMachine(ctx context.Context, in *wflows.ExpectedMachineRequest, opts ...grpc.CallOption) (*wflows.ExpectedMachine, error)

func (*MockCoreGrpcServiceClient) GetExpectedRack added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetExpectedRack(ctx context.Context, in *wflows.ExpectedRackRequest, opts ...grpc.CallOption) (*wflows.ExpectedRack, error)

func (*MockCoreGrpcServiceClient) GetMachineValidationExternalConfigs added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetMachineValidationExternalConfigs(ctx context.Context, in *wflows.GetMachineValidationExternalConfigsRequest, opts ...grpc.CallOption) (*wflows.GetMachineValidationExternalConfigsResponse, error)

func (*MockCoreGrpcServiceClient) GetMachineValidationResults added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetMachineValidationResults(ctx context.Context, in *wflows.MachineValidationGetRequest, opts ...grpc.CallOption) (*wflows.MachineValidationResultList, error)

func (*MockCoreGrpcServiceClient) GetMachineValidationRuns added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetMachineValidationRuns(ctx context.Context, in *wflows.MachineValidationRunListGetRequest, opts ...grpc.CallOption) (*wflows.MachineValidationRunList, error)

func (*MockCoreGrpcServiceClient) GetMachineValidationTests added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetMachineValidationTests(ctx context.Context, in *wflows.MachineValidationTestsGetRequest, opts ...grpc.CallOption) (*wflows.MachineValidationTestsGetResponse, error)

func (*MockCoreGrpcServiceClient) GetNetworkSecurityGroupAttachments added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetNetworkSecurityGroupAttachments(ctx context.Context, in *wflows.GetNetworkSecurityGroupAttachmentsRequest, opts ...grpc.CallOption) (*wflows.GetNetworkSecurityGroupAttachmentsResponse, error)

func (*MockCoreGrpcServiceClient) GetNetworkSecurityGroupPropagationStatus added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetNetworkSecurityGroupPropagationStatus(ctx context.Context, in *wflows.GetNetworkSecurityGroupPropagationStatusRequest, opts ...grpc.CallOption) (*wflows.GetNetworkSecurityGroupPropagationStatusResponse, error)

func (*MockCoreGrpcServiceClient) GetVpcPrefixes added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) GetVpcPrefixes(ctx context.Context, in *wflows.VpcPrefixGetRequest, opts ...grpc.CallOption) (*wflows.VpcPrefixList, error)

func (*MockCoreGrpcServiceClient) InsertHealthReportOverride added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) InsertHealthReportOverride(ctx context.Context, in *wflows.InsertHealthReportOverrideRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) InvokeInstancePower added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) InvokeInstancePower(ctx context.Context, in *wflows.InstancePowerRequest, opts ...grpc.CallOption) (*wflows.InstancePowerResult, error)

func (*MockCoreGrpcServiceClient) ListOsImage added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) ListOsImage(ctx context.Context, in *wflows.ListOsImageRequest, opts ...grpc.CallOption) (*wflows.ListOsImageResponse, error)

func (*MockCoreGrpcServiceClient) MachineValidationTestEnableDisableTest added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) MachineValidationTestEnableDisableTest(ctx context.Context, in *wflows.MachineValidationTestEnableDisableTestRequest, opts ...grpc.CallOption) (*wflows.MachineValidationTestEnableDisableTestResponse, error)

func (*MockCoreGrpcServiceClient) NVLinkLogicalPartitionsForTenant added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) NVLinkLogicalPartitionsForTenant(ctx context.Context, in *wflows.TenantSearchQuery, opts ...grpc.CallOption) (*wflows.NVLinkLogicalPartitionList, error)

func (*MockCoreGrpcServiceClient) PersistValidationResult added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) PersistValidationResult(ctx context.Context, in *wflows.MachineValidationResultPostRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) ReleaseInstance added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) ReleaseInstance(ctx context.Context, in *wflows.InstanceReleaseRequest, opts ...grpc.CallOption) (*wflows.InstanceReleaseResult, error)

func (*MockCoreGrpcServiceClient) RemoveHealthReportOverride added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) RemoveHealthReportOverride(ctx context.Context, in *wflows.RemoveHealthReportOverrideRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) RemoveMachineInstanceTypeAssociation added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) RemoveMachineInstanceTypeAssociation(ctx context.Context, in *wflows.RemoveMachineInstanceTypeAssociationRequest, opts ...grpc.CallOption) (*wflows.RemoveMachineInstanceTypeAssociationResponse, error)

func (*MockCoreGrpcServiceClient) RemoveMachineValidationExternalConfig added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) RemoveMachineValidationExternalConfig(ctx context.Context, in *wflows.RemoveMachineValidationExternalConfigRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) ReplaceAllExpectedRacks added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) ReplaceAllExpectedRacks(ctx context.Context, in *wflows.ExpectedRackList, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) SearchVpcPrefixes added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) SearchVpcPrefixes(ctx context.Context, in *wflows.VpcPrefixSearchQuery, opts ...grpc.CallOption) (*wflows.VpcPrefixIdList, error)

func (*MockCoreGrpcServiceClient) SetMaintenance added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) SetMaintenance(ctx context.Context, in *wflows.MaintenanceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

Machine mock methods

func (*MockCoreGrpcServiceClient) UpdateDpuExtensionService added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateDpuExtensionService(ctx context.Context, in *wflows.UpdateDpuExtensionServiceRequest, opts ...grpc.CallOption) (*wflows.DpuExtensionService, error)

func (*MockCoreGrpcServiceClient) UpdateExpectedMachine added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateExpectedMachine(ctx context.Context, in *wflows.ExpectedMachine, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) UpdateExpectedMachines added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateExpectedMachines(ctx context.Context, in *wflows.BatchExpectedMachineOperationRequest, opts ...grpc.CallOption) (*wflows.BatchExpectedMachineOperationResponse, error)

func (*MockCoreGrpcServiceClient) UpdateExpectedPowerShelf added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateExpectedPowerShelf(ctx context.Context, in *wflows.ExpectedPowerShelf, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) UpdateExpectedRack added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateExpectedRack(ctx context.Context, in *wflows.ExpectedRack, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) UpdateExpectedSwitch added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateExpectedSwitch(ctx context.Context, in *wflows.ExpectedSwitch, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) UpdateIBPartition added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateIBPartition(ctx context.Context, in *wflows.IBPartitionUpdateRequest, opts ...grpc.CallOption) (*wflows.IBPartition, error)

func (*MockCoreGrpcServiceClient) UpdateInstanceConfig added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateInstanceConfig(ctx context.Context, in *wflows.InstanceConfigUpdateRequest, opts ...grpc.CallOption) (*wflows.Instance, error)

func (*MockCoreGrpcServiceClient) UpdateInstanceType added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateInstanceType(ctx context.Context, in *wflows.UpdateInstanceTypeRequest, opts ...grpc.CallOption) (*wflows.UpdateInstanceTypeResponse, error)

func (*MockCoreGrpcServiceClient) UpdateMachineMetadata added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateMachineMetadata(ctx context.Context, in *wflows.MachineMetadataUpdateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockCoreGrpcServiceClient) UpdateMachineValidationRun added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateMachineValidationRun(ctx context.Context, in *wflows.MachineValidationRunRequest, opts ...grpc.CallOption) (*wflows.MachineValidationRunResponse, error)

Network Security Group mock methods

func (*MockCoreGrpcServiceClient) UpdateMachineValidationTest added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateMachineValidationTest(ctx context.Context, in *wflows.MachineValidationTestUpdateRequest, opts ...grpc.CallOption) (*wflows.MachineValidationTestAddUpdateResponse, error)

func (*MockCoreGrpcServiceClient) UpdateNVLinkLogicalPartition added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateNVLinkLogicalPartition(ctx context.Context, in *wflows.NVLinkLogicalPartitionUpdateRequest, opts ...grpc.CallOption) (*wflows.NVLinkLogicalPartitionUpdateResult, error)

func (*MockCoreGrpcServiceClient) UpdateNetworkSecurityGroup added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateNetworkSecurityGroup(ctx context.Context, in *wflows.UpdateNetworkSecurityGroupRequest, opts ...grpc.CallOption) (*wflows.UpdateNetworkSecurityGroupResponse, error)

func (*MockCoreGrpcServiceClient) UpdateOsImage added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateOsImage(ctx context.Context, in *wflows.OsImageAttributes, opts ...grpc.CallOption) (*wflows.OsImage, error)

func (*MockCoreGrpcServiceClient) UpdateTenant added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateTenant(ctx context.Context, in *wflows.UpdateTenantRequest, opts ...grpc.CallOption) (*wflows.UpdateTenantResponse, error)

func (*MockCoreGrpcServiceClient) UpdateTenantKeyset added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateTenantKeyset(ctx context.Context, in *wflows.UpdateTenantKeysetRequest, opts ...grpc.CallOption) (*wflows.UpdateTenantKeysetResponse, error)

func (*MockCoreGrpcServiceClient) UpdateVpc added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateVpc(ctx context.Context, in *wflows.VpcUpdateRequest, opts ...grpc.CallOption) (*wflows.VpcUpdateResult, error)

func (*MockCoreGrpcServiceClient) UpdateVpcPrefix added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateVpcPrefix(ctx context.Context, in *wflows.VpcPrefixUpdateRequest, opts ...grpc.CallOption) (*wflows.VpcPrefix, error)

func (*MockCoreGrpcServiceClient) UpdateVpcVirtualization added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) UpdateVpcVirtualization(ctx context.Context, in *wflows.VpcUpdateVirtualizationRequest, opts ...grpc.CallOption) (*wflows.VpcUpdateVirtualizationResult, error)

func (*MockCoreGrpcServiceClient) Version added in v1.6.0 

func (mcgsc *MockCoreGrpcServiceClient) Version(ctx context.Context, in *wflows.VersionRequest, opts ...grpc.CallOption) (*wflows.BuildInfo, error)

Version mock methods

type MockFlowGrpcServiceClient added in v1.6.0 

type MockFlowGrpcServiceClient struct {
	flowv1.FlowClient
}

MockFlowGrpcService is a mock implementation of Flow gRPC protobuf Service

func (*MockFlowGrpcServiceClient) AddComponent added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) AddComponent(ctx context.Context, in *flowv1.AddComponentRequest, opts ...grpc.CallOption) (*flowv1.AddComponentResponse, error)

Component mutation mock methods

func (*MockFlowGrpcServiceClient) AssociateRuleWithRack added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) AssociateRuleWithRack(ctx context.Context, in *flowv1.AssociateRuleWithRackRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

Rack-rule association mock methods

func (*MockFlowGrpcServiceClient) AttachRacksToNVLDomain added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) AttachRacksToNVLDomain(ctx context.Context, in *flowv1.AttachRacksToNVLDomainRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockFlowGrpcServiceClient) BringUpRack added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) BringUpRack(ctx context.Context, in *flowv1.BringUpRackRequest, opts ...grpc.CallOption) (*flowv1.SubmitTaskResponse, error)

func (*MockFlowGrpcServiceClient) CancelTask added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) CancelTask(ctx context.Context, in *flowv1.CancelTaskRequest, opts ...grpc.CallOption) (*flowv1.CancelTaskResponse, error)

func (*MockFlowGrpcServiceClient) CreateExpectedRack added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) CreateExpectedRack(ctx context.Context, in *flowv1.CreateExpectedRackRequest, opts ...grpc.CallOption) (*flowv1.CreateExpectedRackResponse, error)

Rack mock methods

func (*MockFlowGrpcServiceClient) CreateNVLDomain added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) CreateNVLDomain(ctx context.Context, in *flowv1.CreateNVLDomainRequest, opts ...grpc.CallOption) (*flowv1.CreateNVLDomainResponse, error)

NVL Domain mock methods

func (*MockFlowGrpcServiceClient) CreateOperationRule added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) CreateOperationRule(ctx context.Context, in *flowv1.CreateOperationRuleRequest, opts ...grpc.CallOption) (*flowv1.CreateOperationRuleResponse, error)

Operation rule mock methods

func (*MockFlowGrpcServiceClient) DeleteComponent added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) DeleteComponent(ctx context.Context, in *flowv1.DeleteComponentRequest, opts ...grpc.CallOption) (*flowv1.DeleteComponentResponse, error)

func (*MockFlowGrpcServiceClient) DeleteOperationRule added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) DeleteOperationRule(ctx context.Context, in *flowv1.DeleteOperationRuleRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockFlowGrpcServiceClient) DetachRacksFromNVLDomain added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) DetachRacksFromNVLDomain(ctx context.Context, in *flowv1.DetachRacksFromNVLDomainRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockFlowGrpcServiceClient) DisassociateRuleFromRack added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) DisassociateRuleFromRack(ctx context.Context, in *flowv1.DisassociateRuleFromRackRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockFlowGrpcServiceClient) GetComponentInfoByID added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) GetComponentInfoByID(ctx context.Context, in *flowv1.GetComponentInfoByIDRequest, opts ...grpc.CallOption) (*flowv1.GetComponentInfoResponse, error)

Component mock methods

func (*MockFlowGrpcServiceClient) GetComponentInfoBySerial added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) GetComponentInfoBySerial(ctx context.Context, in *flowv1.GetComponentInfoBySerialRequest, opts ...grpc.CallOption) (*flowv1.GetComponentInfoResponse, error)

func (*MockFlowGrpcServiceClient) GetComponents added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) GetComponents(ctx context.Context, in *flowv1.GetComponentsRequest, opts ...grpc.CallOption) (*flowv1.GetComponentsResponse, error)

func (*MockFlowGrpcServiceClient) GetListOfNVLDomains added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) GetListOfNVLDomains(ctx context.Context, in *flowv1.GetListOfNVLDomainsRequest, opts ...grpc.CallOption) (*flowv1.GetListOfNVLDomainsResponse, error)

func (*MockFlowGrpcServiceClient) GetListOfRacks added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) GetListOfRacks(ctx context.Context, in *flowv1.GetListOfRacksRequest, opts ...grpc.CallOption) (*flowv1.GetListOfRacksResponse, error)

func (*MockFlowGrpcServiceClient) GetOperationRule added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) GetOperationRule(ctx context.Context, in *flowv1.GetOperationRuleRequest, opts ...grpc.CallOption) (*flowv1.OperationRule, error)

func (*MockFlowGrpcServiceClient) GetRackInfoByID added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) GetRackInfoByID(ctx context.Context, in *flowv1.GetRackInfoByIDRequest, opts ...grpc.CallOption) (*flowv1.GetRackInfoResponse, error)

func (*MockFlowGrpcServiceClient) GetRackInfoBySerial added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) GetRackInfoBySerial(ctx context.Context, in *flowv1.GetRackInfoBySerialRequest, opts ...grpc.CallOption) (*flowv1.GetRackInfoResponse, error)

func (*MockFlowGrpcServiceClient) GetRackRuleAssociation added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) GetRackRuleAssociation(ctx context.Context, in *flowv1.GetRackRuleAssociationRequest, opts ...grpc.CallOption) (*flowv1.GetRackRuleAssociationResponse, error)

func (*MockFlowGrpcServiceClient) GetRacksForNVLDomain added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) GetRacksForNVLDomain(ctx context.Context, in *flowv1.GetRacksForNVLDomainRequest, opts ...grpc.CallOption) (*flowv1.GetRacksForNVLDomainResponse, error)

func (*MockFlowGrpcServiceClient) GetTasksByIDs added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) GetTasksByIDs(ctx context.Context, in *flowv1.GetTasksByIDsRequest, opts ...grpc.CallOption) (*flowv1.GetTasksByIDsResponse, error)

func (*MockFlowGrpcServiceClient) IngestRack added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) IngestRack(ctx context.Context, in *flowv1.IngestRackRequest, opts ...grpc.CallOption) (*flowv1.SubmitTaskResponse, error)

func (*MockFlowGrpcServiceClient) ListOperationRules added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) ListOperationRules(ctx context.Context, in *flowv1.ListOperationRulesRequest, opts ...grpc.CallOption) (*flowv1.ListOperationRulesResponse, error)

func (*MockFlowGrpcServiceClient) ListRackRuleAssociations added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) ListRackRuleAssociations(ctx context.Context, in *flowv1.ListRackRuleAssociationsRequest, opts ...grpc.CallOption) (*flowv1.ListRackRuleAssociationsResponse, error)

func (*MockFlowGrpcServiceClient) ListTasks added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) ListTasks(ctx context.Context, in *flowv1.ListTasksRequest, opts ...grpc.CallOption) (*flowv1.ListTasksResponse, error)

func (*MockFlowGrpcServiceClient) PatchComponent added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) PatchComponent(ctx context.Context, in *flowv1.PatchComponentRequest, opts ...grpc.CallOption) (*flowv1.PatchComponentResponse, error)

func (*MockFlowGrpcServiceClient) PatchRack added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) PatchRack(ctx context.Context, in *flowv1.PatchRackRequest, opts ...grpc.CallOption) (*flowv1.PatchRackResponse, error)

func (*MockFlowGrpcServiceClient) PowerOffRack added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) PowerOffRack(ctx context.Context, in *flowv1.PowerOffRackRequest, opts ...grpc.CallOption) (*flowv1.SubmitTaskResponse, error)

func (*MockFlowGrpcServiceClient) PowerOnRack added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) PowerOnRack(ctx context.Context, in *flowv1.PowerOnRackRequest, opts ...grpc.CallOption) (*flowv1.SubmitTaskResponse, error)

func (*MockFlowGrpcServiceClient) PowerResetRack added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) PowerResetRack(ctx context.Context, in *flowv1.PowerResetRackRequest, opts ...grpc.CallOption) (*flowv1.SubmitTaskResponse, error)

func (*MockFlowGrpcServiceClient) SetRuleAsDefault added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) SetRuleAsDefault(ctx context.Context, in *flowv1.SetRuleAsDefaultRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockFlowGrpcServiceClient) UpdateOperationRule added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) UpdateOperationRule(ctx context.Context, in *flowv1.UpdateOperationRuleRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

func (*MockFlowGrpcServiceClient) UpgradeFirmware added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) UpgradeFirmware(ctx context.Context, in *flowv1.UpgradeFirmwareRequest, opts ...grpc.CallOption) (*flowv1.SubmitTaskResponse, error)

Task mock methods

func (*MockFlowGrpcServiceClient) ValidateComponents added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) ValidateComponents(ctx context.Context, in *flowv1.ValidateComponentsRequest, opts ...grpc.CallOption) (*flowv1.ValidateComponentsResponse, error)

func (*MockFlowGrpcServiceClient) Version added in v1.6.0 

func (mfgsc *MockFlowGrpcServiceClient) Version(ctx context.Context, in *flowv1.VersionRequest, opts ...grpc.CallOption) (*flowv1.BuildInfo, error)

Version mock methods

type SecureOptions 

type SecureOptions int

SecureOptions is the enum for the secure options

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.