client

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: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrFlowClientInvalidAddress    = errors.New("FlowClient: invalid address")
	ErrFlowClientInvalidDialOpts   = errors.New("FlowClient: invalid dial options")
	ErrFlowClientInvalidSecureOpts = errors.New("FlowClient: invalid secure options")
	ErrFlowClientInvalidServerCA   = errors.New("FlowClient: invalid server CA")
	ErrFlowClientInvalidClientCA   = errors.New("FlowClient: invalid client CA")
	ErrFlowClientInvalidClientKey  = errors.New("FlowClient: invalid client key")
	ErrFlowClientInvalidClientCert = errors.New("FlowClient: invalid client cert")
)

Errors

View Source 
var (
	ErrNICoCoreClientInvalidAddress    = errors.New("NICoCoreClient: invalid address")
	ErrNICoCoreClientInvalidDialOpts   = errors.New("NICoCoreClient: invalid dial options")
	ErrNICoCoreClientInvalidSecureOpts = errors.New("NICoCoreClient: invalid secure options")
	ErrNICoCoreClientInvalidServerCA   = errors.New("NICoCoreClient: invalid server CA")
	ErrNICoCoreClientInvalidClientCA   = errors.New("NICoCoreClient: invalid client CA")
	ErrNICoCoreClientInvalidClientKey  = errors.New("NICoCoreClient: invalid client key")
	ErrNICoCoreClientInvalidClientCert = errors.New("NICoCoreClient: invalid client cert")
	ErrClientNotConnected              = errors.New("gRPC client is not connected to the server")
)

Errors

Functions

func SliceToChunks 

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

Types

type FlowAtomicClient 

type FlowAtomicClient struct {
	Config *FlowClientConfig
	// contains filtered or unexported fields
}

FlowAtomicClient is an atomic wrapper around the FlowClient

func NewFlowAtomicClient 

func NewFlowAtomicClient(config *FlowClientConfig) *FlowAtomicClient

NewFlowAtomicClient creates a new FlowAtomicClient

func (*FlowAtomicClient) CheckAndReloadCerts 

func (rac *FlowAtomicClient) CheckAndReloadCerts(initialClientCertMD5, initialServerCAMD5 []byte)

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

func (*FlowAtomicClient) CheckCertificates 

func (rac *FlowAtomicClient) CheckCertificates(lastClientCertMD5, lastServerCAMD5 []byte) (bool, []byte, []byte, error)

CheckCertificates checks if the client and server CA certificates have changed

func (*FlowAtomicClient) GetClient 

func (rac *FlowAtomicClient) GetClient() *FlowClient

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

func (*FlowAtomicClient) GetFlowClient 

func (rac *FlowAtomicClient) GetFlowClient() (flowv1.FlowClient, error)

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

func (*FlowAtomicClient) GetInitialCertMD5 

func (rac *FlowAtomicClient) GetInitialCertMD5() (clientCertMD5, serverCAMD5 []byte, err error)

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

func (*FlowAtomicClient) SwapClient 

func (rac *FlowAtomicClient) SwapClient(newClient *FlowClient) *FlowClient

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

func (*FlowAtomicClient) Version 

func (rac *FlowAtomicClient) Version() int64

Version returns the current version of the FlowClient

type FlowClient 

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

FlowClient is the data structure for the client

func NewFlowClient 

func NewFlowClient(config *FlowClientConfig) (client *FlowClient, err error)

NewFlowClient creates a new FlowClient

func NewMockFlowClient 

func NewMockFlowClient() *FlowClient

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

func (*FlowClient) Close 

func (cc *FlowClient) Close() error

Close gracefully shuts down the client's gRPC connection.

func (*FlowClient) Flow 

func (client *FlowClient) Flow() flowv1.FlowClient

Flow client getter

type FlowClientConfig 

type FlowClientConfig struct {
	// The address of the server <host>:<port>
	Address string
	// Secure flag
	Secure FlowClientSecureOptions
	// 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 FlowClientSecureOptions 

type FlowClientSecureOptions int

SecureOptions is the enum for the secure options 

const (
	// FlowInsecureGrpc is the insecure dial option
	FlowInsecureGrpc FlowClientSecureOptions = iota
	// FlowServerTLS is the secure dial option for server tls
	FlowServerTLS
	// FlowMutualTLS for mutual tls
	FlowMutualTLS
)

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 MockFlowClient 

type MockFlowClient struct {
	flowv1.FlowClient
}

MockFlowClient is a mock implementation of Flow gRPC protobuf Client

func (*MockFlowClient) AddComponent 

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

Component mutation mock methods

func (*MockFlowClient) AssociateRuleWithRack 

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

Rack-rule association mock methods

func (*MockFlowClient) AttachRacksToNVLDomain 

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

func (*MockFlowClient) BringUpRack 

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

func (*MockFlowClient) CancelTask 

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

func (*MockFlowClient) CreateExpectedRack 

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

Rack mock methods

func (*MockFlowClient) CreateNVLDomain 

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

NVL Domain mock methods

func (*MockFlowClient) CreateOperationRule 

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

Operation rule mock methods

func (*MockFlowClient) DeleteComponent 

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

func (*MockFlowClient) DeleteOperationRule 

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

func (*MockFlowClient) DetachRacksFromNVLDomain 

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

func (*MockFlowClient) DisassociateRuleFromRack 

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

func (*MockFlowClient) GetComponentInfoByID 

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

Component mock methods

func (*MockFlowClient) GetComponentInfoBySerial 

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

func (*MockFlowClient) GetComponents 

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

func (*MockFlowClient) GetListOfNVLDomains 

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

func (*MockFlowClient) GetListOfRacks 

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

func (*MockFlowClient) GetOperationRule 

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

func (*MockFlowClient) GetRackInfoByID 

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

func (*MockFlowClient) GetRackInfoBySerial 

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

func (*MockFlowClient) GetRackRuleAssociation 

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

func (*MockFlowClient) GetRacksForNVLDomain 

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

func (*MockFlowClient) GetTasksByIDs 

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

func (*MockFlowClient) IngestRack 

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

func (*MockFlowClient) ListOperationRules 

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

func (*MockFlowClient) ListRackRuleAssociations 

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

func (*MockFlowClient) ListTasks 

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

func (*MockFlowClient) PatchComponent 

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

func (*MockFlowClient) PatchRack 

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

func (*MockFlowClient) PowerOffRack 

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

func (*MockFlowClient) PowerOnRack 

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

func (*MockFlowClient) PowerResetRack 

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

func (*MockFlowClient) SetRuleAsDefault 

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

func (*MockFlowClient) UpdateOperationRule 

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

func (*MockFlowClient) UpgradeFirmware 

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

Task mock methods

func (*MockFlowClient) ValidateComponents 

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

func (*MockFlowClient) Version 

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

Version mock methods

type MockNICoClient 

type MockNICoClient struct {
	wflows.ForgeClient
}

MockNICoClient is a mock implementation of NICo gRPC protobuf Client

func (*MockNICoClient) AddExpectedMachine 

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

Expected Machine mock methods

func (*MockNICoClient) AddExpectedPowerShelf 

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

Expected Power Shelf mock methods

func (*MockNICoClient) AddExpectedRack 

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

Expected Rack mock methods

func (*MockNICoClient) AddExpectedSwitch 

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

Expected Switch mock methods

func (*MockNICoClient) AddMachineValidationTest 

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

Machine Validation Test mock methods

func (*MockNICoClient) AddUpdateMachineValidationExternalConfig 

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

func (*MockNICoClient) AllocateInstance 

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

Instance mock methods

func (*MockNICoClient) AllocateInstances 

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

func (*MockNICoClient) AssociateMachinesWithInstanceType 

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

func (*MockNICoClient) CreateDpuExtensionService 

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

DPU Extension Service mock methods

func (*MockNICoClient) CreateExpectedMachines 

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

func (*MockNICoClient) CreateIBPartition 

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

InfiniBand Partition mock methods

func (*MockNICoClient) CreateInstanceType 

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

Instance Type mock methods

func (*MockNICoClient) CreateNVLinkLogicalPartition 

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

NVLink Logical Partition Mocks

func (*MockNICoClient) CreateNetworkSecurityGroup 

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

func (*MockNICoClient) CreateNetworkSegment 

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

func (*MockNICoClient) CreateOsImage 

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

OS Image mock methods

func (*MockNICoClient) CreateTenant 

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

Tenant mock methods

func (*MockNICoClient) CreateTenantKeyset 

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

Tenant Keyset mock methods

func (*MockNICoClient) CreateVpc 

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

VPC mock methods

func (*MockNICoClient) CreateVpcPeering 

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

VPC Peering mock methods

func (*MockNICoClient) CreateVpcPrefix 

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

VPC Prefix mock methods

func (*MockNICoClient) DeleteAllExpectedRacks 

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

func (*MockNICoClient) DeleteDpuExtensionService 

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

func (*MockNICoClient) DeleteExpectedMachine 

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

func (*MockNICoClient) DeleteExpectedPowerShelf 

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

func (*MockNICoClient) DeleteExpectedRack 

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

func (*MockNICoClient) DeleteExpectedSwitch 

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

func (*MockNICoClient) DeleteIBPartition 

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

func (*MockNICoClient) DeleteInstanceType 

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

func (*MockNICoClient) DeleteNVLinkLogicalPartition 

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

func (*MockNICoClient) DeleteNetworkSecurityGroup 

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

func (*MockNICoClient) DeleteNetworkSegment 

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

func (*MockNICoClient) DeleteOsImage 

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

func (*MockNICoClient) DeleteTenantKeyset 

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

func (*MockNICoClient) DeleteVpc 

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

func (*MockNICoClient) DeleteVpcPeering 

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

func (*MockNICoClient) DeleteVpcPrefix 

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

func (*MockNICoClient) FindDpuExtensionServiceIds 

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

func (*MockNICoClient) FindDpuExtensionServicesByIds 

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

func (*MockNICoClient) FindIBPartitionIds 

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

func (*MockNICoClient) FindIBPartitionsByIds 

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

func (*MockNICoClient) FindInstanceIds 

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

func (*MockNICoClient) FindInstanceTypeIds 

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

func (*MockNICoClient) FindInstanceTypesByIds 

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

func (*MockNICoClient) FindInstancesByIds 

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

func (*MockNICoClient) FindMachineIds 

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

func (*MockNICoClient) FindMachinesByIds 

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

func (*MockNICoClient) FindNVLinkLogicalPartitionIds 

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

func (*MockNICoClient) FindNVLinkLogicalPartitionsByIds 

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

func (*MockNICoClient) FindNetworkSecurityGroupIds 

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

func (*MockNICoClient) FindNetworkSecurityGroupsByIds 

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

func (*MockNICoClient) FindNetworkSegmentIds 

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

func (*MockNICoClient) FindNetworkSegmentsByIds 

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

func (*MockNICoClient) FindSkusByIds 

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

SKU mock methods

func (*MockNICoClient) FindTenant 

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

func (*MockNICoClient) FindTenantKeysetIds 

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

func (*MockNICoClient) FindTenantKeysetsByIds 

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

func (*MockNICoClient) FindTenantOrganizationIds 

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

func (*MockNICoClient) FindTenantsByOrganizationIds 

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

func (*MockNICoClient) FindVpcIds 

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

func (*MockNICoClient) FindVpcPeeringIds 

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

func (*MockNICoClient) FindVpcPeeringsByIds 

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

func (*MockNICoClient) FindVpcsByIds 

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

func (*MockNICoClient) GetAllExpectedMachines 

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

func (*MockNICoClient) GetAllExpectedMachinesLinked 

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

func (*MockNICoClient) GetAllExpectedPowerShelves 

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

func (*MockNICoClient) GetAllExpectedPowerShelvesLinked 

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

func (*MockNICoClient) GetAllExpectedRacks 

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

func (*MockNICoClient) GetAllExpectedSwitches 

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

func (*MockNICoClient) GetAllExpectedSwitchesLinked 

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

func (*MockNICoClient) GetAllSkuIds 

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

func (*MockNICoClient) GetDpuExtensionServiceVersionsInfo 

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

func (*MockNICoClient) GetExpectedMachine 

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

func (*MockNICoClient) GetExpectedRack 

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

func (*MockNICoClient) GetMachineValidationExternalConfigs 

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

func (*MockNICoClient) GetMachineValidationResults 

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

func (*MockNICoClient) GetMachineValidationRuns 

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

func (*MockNICoClient) GetMachineValidationTests 

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

func (*MockNICoClient) GetNetworkSecurityGroupAttachments 

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

func (*MockNICoClient) GetNetworkSecurityGroupPropagationStatus 

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

func (*MockNICoClient) GetVpcPrefixes 

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

func (*MockNICoClient) InvokeInstancePower 

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

func (*MockNICoClient) ListOsImage 

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

func (*MockNICoClient) MachineValidationTestEnableDisableTest 

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

func (*MockNICoClient) NVLinkLogicalPartitionsForTenant 

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

func (*MockNICoClient) PersistValidationResult 

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

func (*MockNICoClient) ReleaseInstance 

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

func (*MockNICoClient) RemoveMachineInstanceTypeAssociation 

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

func (*MockNICoClient) RemoveMachineValidationExternalConfig 

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

func (*MockNICoClient) ReplaceAllExpectedRacks 

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

func (*MockNICoClient) SearchVpcPrefixes 

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

func (*MockNICoClient) SetMaintenance 

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

Machine mock methods

func (*MockNICoClient) UpdateDpuExtensionService 

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

func (*MockNICoClient) UpdateExpectedMachine 

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

func (*MockNICoClient) UpdateExpectedMachines 

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

func (*MockNICoClient) UpdateExpectedPowerShelf 

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

func (*MockNICoClient) UpdateExpectedRack 

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

func (*MockNICoClient) UpdateExpectedSwitch 

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

func (*MockNICoClient) UpdateIBPartition 

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

func (*MockNICoClient) UpdateInstanceConfig 

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

func (*MockNICoClient) UpdateInstanceType 

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

func (*MockNICoClient) UpdateMachineMetadata 

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

func (*MockNICoClient) UpdateMachineValidationRun 

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

Network Security Group mock methods

func (*MockNICoClient) UpdateMachineValidationTest 

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

func (*MockNICoClient) UpdateNVLinkLogicalPartition 

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

func (*MockNICoClient) UpdateNetworkSecurityGroup 

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

func (*MockNICoClient) UpdateOsImage 

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

func (*MockNICoClient) UpdateTenant 

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

func (*MockNICoClient) UpdateTenantKeyset 

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

func (*MockNICoClient) UpdateVpc 

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

func (*MockNICoClient) UpdateVpcPrefix 

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

func (*MockNICoClient) UpdateVpcVirtualization 

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

func (*MockNICoClient) Version 

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

Version mock methods

type NICoCoreAtomicClient 

type NICoCoreAtomicClient struct {
	Config *NICoCoreClientConfig
	// contains filtered or unexported fields
}

NICoCoreAtomicClient is an atomic wrapper around the NICoCoreClient

func NewNICoCoreAtomicClient 

func NewNICoCoreAtomicClient(config *NICoCoreClientConfig) *NICoCoreAtomicClient

NewNICoCoreAtomicClient creates a new NICoCoreAtomicClient

func (*NICoCoreAtomicClient) CheckAndReloadCerts 

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

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

func (*NICoCoreAtomicClient) CheckCertificates 

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

CheckCertificates checks if the client and server CA certificates have changed

func (*NICoCoreAtomicClient) GetClient 

func (cac *NICoCoreAtomicClient) GetClient() *NICoCoreClient

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

func (*NICoCoreAtomicClient) GetInitialCertMD5 

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

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

func (*NICoCoreAtomicClient) SwapClient 

func (cac *NICoCoreAtomicClient) SwapClient(newClient *NICoCoreClient) *NICoCoreClient

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

func (*NICoCoreAtomicClient) Version 

func (cac *NICoCoreAtomicClient) Version() int64

Version returns the current version of the NICoCoreClient

type NICoCoreClient 

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

NICoCoreClient is the data structure for the client

func NewMockNICoClient 

func NewMockNICoClient() *NICoCoreClient

NewMockNICoClient creates a new mock NICoCoreClient

func NewNICoCoreClient 

func NewNICoCoreClient(config *NICoCoreClientConfig) (client *NICoCoreClient, err error)

NewNICoCoreClient creates a new NICoCoreClient

func (*NICoCoreClient) Close 

func (cc *NICoCoreClient) Close() error

Close gracefully shuts down the client's gRPC connection.

func (*NICoCoreClient) NICo 

func (client *NICoCoreClient) NICo() wflows.ForgeClient

NICo client getter

type NICoCoreClientConfig 

type NICoCoreClientConfig 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
}

NICoCoreClientConfig is the data structure for the client configuration

type SecureOptions 

type SecureOptions int

SecureOptions is the enum for the secure options 

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
)

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.