activity

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Mar 17, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Overview

* SPDX-FileCopyrightText: Copyright (c) 2026 NVIDIA CORPORATION & AFFILIATES. All rights reserved. * SPDX-License-Identifier: Apache-2.0 * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func VpcPeeringFindByIDs 

func VpcPeeringFindByIDs(ctx context.Context, carbideClient *cClient.CarbideClient, ids []*cwssaws.VpcPeeringId) ([]*cwssaws.VpcPeering, error)

func VpcPeeringFindIDs 

func VpcPeeringFindIDs(ctx context.Context, carbideClient *cClient.CarbideClient) ([]*cwssaws.VpcPeeringId, error)

func VpcPeeringPagedInventory 

func VpcPeeringPagedInventory(allItemIDs []*cwssaws.VpcPeeringId, pagedItems []*cwssaws.VpcPeering, input *pagedInventoryInput) *cwssaws.VPCPeeringInventory

func VpcPrefixFindByIDs 

func VpcPrefixFindByIDs(ctx context.Context, carbideClient *cClient.CarbideClient, ids []*cwssaws.VpcPrefixId) ([]*cwssaws.VpcPrefix, error)

func VpcPrefixFindFallback 

func VpcPrefixFindFallback(ctx context.Context, carbideClient *cClient.CarbideClient) ([]*cwssaws.VpcPrefixId, []*cwssaws.VpcPrefix, error)

func VpcPrefixFindIDs 

func VpcPrefixFindIDs(ctx context.Context, carbideClient *cClient.CarbideClient) ([]*cwssaws.VpcPrefixId, error)

func VpcPrefixPagedInventory 

func VpcPrefixPagedInventory(allItemIDs []*cwssaws.VpcPrefixId, pagedItems []*cwssaws.VpcPrefix, input *pagedInventoryInput) *cwssaws.VpcPrefixInventory

Types

type ManageDpuExtensionService 

type ManageDpuExtensionService struct {
	CarbideAtomicClient *cclient.CarbideAtomicClient
}

ManageDpuExtensionService is an activity wrapper for DPU Extension Service management

func NewManageDpuExtensionService 

func NewManageDpuExtensionService(carbideClient *cclient.CarbideAtomicClient) ManageDpuExtensionService

NewManageDpuExtensionService returns a new ManageDpuExtensionService activity

func (*ManageDpuExtensionService) CreateDpuExtensionServiceOnSite 

func (mdes *ManageDpuExtensionService) CreateDpuExtensionServiceOnSite(ctx context.Context, request *cwssaws.CreateDpuExtensionServiceRequest) (*cwssaws.DpuExtensionService, error)

CreateDpuExtensionServiceOnSite is an activity to create a new DPU Extension Service on Site

func (*ManageDpuExtensionService) DeleteDpuExtensionServiceOnSite 

func (mdes *ManageDpuExtensionService) DeleteDpuExtensionServiceOnSite(ctx context.Context, request *cwssaws.DeleteDpuExtensionServiceRequest) error

DeleteDpuExtensionServiceOnSite is an activity to delete a DPU Extension Service on Site

func (*ManageDpuExtensionService) GetDpuExtensionServiceVersionsInfoOnSite 

func (mdes *ManageDpuExtensionService) GetDpuExtensionServiceVersionsInfoOnSite(ctx context.Context, request *cwssaws.GetDpuExtensionServiceVersionsInfoRequest) (*cwssaws.DpuExtensionServiceVersionInfoList, error)

GetDpuExtensionServiceVersionsInfoOnSite is an activity to get detailed information for various versions of a DPU Extension Service on Site

func (*ManageDpuExtensionService) UpdateDpuExtensionServiceOnSite 

func (mdes *ManageDpuExtensionService) UpdateDpuExtensionServiceOnSite(ctx context.Context, request *cwssaws.UpdateDpuExtensionServiceRequest) (*cwssaws.DpuExtensionService, error)

UpdateDpuExtensionServiceOnSite is an activity to update a DPU Extension Service on Site

type ManageDpuExtensionServiceInventory 

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

func NewManageDpuExtensionServiceInventory 

func NewManageDpuExtensionServiceInventory(config ManageInventoryConfig) ManageDpuExtensionServiceInventory

NewManageDpuExtensionServiceInventory returns a ManageInventory implementation for DPU Extension Service activity

func (*ManageDpuExtensionServiceInventory) DiscoverDpuExtensionServiceInventory 

func (msi *ManageDpuExtensionServiceInventory) DiscoverDpuExtensionServiceInventory(ctx context.Context) error

DiscoverDpuExtensionServiceInventory is an activity to discover DPU Extension Services on Site and publish to Temporal queue

type ManageExpectedMachine 

type ManageExpectedMachine struct {
	CarbideAtomicClient *cclient.CarbideAtomicClient
}

ManageExpectedMachine is an activity wrapper for Expected Machine management

func NewManageExpectedMachine 

func NewManageExpectedMachine(carbideClient *cclient.CarbideAtomicClient) ManageExpectedMachine

NewManageExpectedMachine returns a new ManageExpectedMachine client

func (*ManageExpectedMachine) CreateExpectedMachineOnSite 

func (mem *ManageExpectedMachine) CreateExpectedMachineOnSite(ctx context.Context, request *cwssaws.ExpectedMachine) error

CreateExpectedMachineOnSite creates Expected Machine with Carbide

func (*ManageExpectedMachine) CreateExpectedMachinesOnSite 

func (mem *ManageExpectedMachine) CreateExpectedMachinesOnSite(ctx context.Context, request *cwssaws.BatchExpectedMachineOperationRequest) (*cwssaws.BatchExpectedMachineOperationResponse, error)

CreateExpectedMachinesOnSite creates multiple Expected Machines with Carbide using the carbide batch endpoint

func (*ManageExpectedMachine) DeleteExpectedMachineOnSite 

func (mem *ManageExpectedMachine) DeleteExpectedMachineOnSite(ctx context.Context, request *cwssaws.ExpectedMachineRequest) error

DeleteExpectedMachineOnSite deletes Expected Machine on Carbide

func (*ManageExpectedMachine) UpdateExpectedMachineOnSite 

func (mem *ManageExpectedMachine) UpdateExpectedMachineOnSite(ctx context.Context, request *cwssaws.ExpectedMachine) error

UpdateExpectedMachineOnSite updates Expected Machine on Carbide

func (*ManageExpectedMachine) UpdateExpectedMachinesOnSite 

func (mem *ManageExpectedMachine) UpdateExpectedMachinesOnSite(ctx context.Context, request *cwssaws.BatchExpectedMachineOperationRequest) (*cwssaws.BatchExpectedMachineOperationResponse, error)

UpdateExpectedMachinesOnSite updates multiple Expected Machines on Carbide using the batch endpoint

type ManageExpectedMachineInventory 

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

ManageExpectedMachineInventory is an activity wrapper for Expected Machine inventory collection and publishing

func NewManageExpectedMachineInventory 

func NewManageExpectedMachineInventory(siteID uuid.UUID, carbideAtomicClient *cclient.CarbideAtomicClient, temporalPublishClient tClient.Client, temporalPublishQueue string, cloudPageSize int) ManageExpectedMachineInventory

NewManageExpectedMachineInventory returns a ManageInventory implementation for Expected Machine activity

func (*ManageExpectedMachineInventory) DiscoverExpectedMachineInventory 

func (memi *ManageExpectedMachineInventory) DiscoverExpectedMachineInventory(ctx context.Context) error

DiscoverExpectedMachineInventory is an activity to collect Expected Machine inventory and publish to Temporal queue

type ManageExpectedPowerShelf 

type ManageExpectedPowerShelf struct {
	CarbideAtomicClient *cclient.CarbideAtomicClient
}

ManageExpectedPowerShelf is an activity wrapper for Expected Power Shelf management

func NewManageExpectedPowerShelf 

func NewManageExpectedPowerShelf(carbideClient *cclient.CarbideAtomicClient) ManageExpectedPowerShelf

NewManageExpectedPowerShelf returns a new ManageExpectedPowerShelf client

func (*ManageExpectedPowerShelf) CreateExpectedPowerShelfOnSite 

func (meps *ManageExpectedPowerShelf) CreateExpectedPowerShelfOnSite(ctx context.Context, request *cwssaws.ExpectedPowerShelf) error

CreateExpectedPowerShelfOnSite creates Expected Power Shelf with Carbide

func (*ManageExpectedPowerShelf) DeleteExpectedPowerShelfOnSite 

func (meps *ManageExpectedPowerShelf) DeleteExpectedPowerShelfOnSite(ctx context.Context, request *cwssaws.ExpectedPowerShelfRequest) error

DeleteExpectedPowerShelfOnSite deletes Expected Power Shelf on Carbide

func (*ManageExpectedPowerShelf) UpdateExpectedPowerShelfOnSite 

func (meps *ManageExpectedPowerShelf) UpdateExpectedPowerShelfOnSite(ctx context.Context, request *cwssaws.ExpectedPowerShelf) error

UpdateExpectedPowerShelfOnSite updates Expected Power Shelf on Carbide

type ManageExpectedPowerShelfInventory 

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

ManageExpectedPowerShelfInventory is an activity wrapper for Expected Power Shelf inventory collection and publishing

func NewManageExpectedPowerShelfInventory 

func NewManageExpectedPowerShelfInventory(siteID uuid.UUID, carbideAtomicClient *cclient.CarbideAtomicClient, temporalPublishClient tClient.Client, temporalPublishQueue string, cloudPageSize int) ManageExpectedPowerShelfInventory

NewManageExpectedPowerShelfInventory returns a ManageInventory implementation for Expected Power Shelf activity

func (*ManageExpectedPowerShelfInventory) DiscoverExpectedPowerShelfInventory 

func (mepsi *ManageExpectedPowerShelfInventory) DiscoverExpectedPowerShelfInventory(ctx context.Context) error

DiscoverExpectedPowerShelfInventory is an activity to collect Expected Power Shelf inventory and publish to Temporal queue

type ManageExpectedSwitch 

type ManageExpectedSwitch struct {
	CarbideAtomicClient *cclient.CarbideAtomicClient
}

ManageExpectedSwitch is an activity wrapper for Expected Switch management

func NewManageExpectedSwitch 

func NewManageExpectedSwitch(carbideClient *cclient.CarbideAtomicClient) ManageExpectedSwitch

NewManageExpectedSwitch returns a new ManageExpectedSwitch client

func (*ManageExpectedSwitch) CreateExpectedSwitchOnSite 

func (mes *ManageExpectedSwitch) CreateExpectedSwitchOnSite(ctx context.Context, request *cwssaws.ExpectedSwitch) error

CreateExpectedSwitchOnSite creates Expected Switch with Carbide

func (*ManageExpectedSwitch) DeleteExpectedSwitchOnSite 

func (mes *ManageExpectedSwitch) DeleteExpectedSwitchOnSite(ctx context.Context, request *cwssaws.ExpectedSwitchRequest) error

DeleteExpectedSwitchOnSite deletes Expected Switch on Carbide

func (*ManageExpectedSwitch) UpdateExpectedSwitchOnSite 

func (mes *ManageExpectedSwitch) UpdateExpectedSwitchOnSite(ctx context.Context, request *cwssaws.ExpectedSwitch) error

UpdateExpectedSwitchOnSite updates Expected Switch on Carbide

type ManageExpectedSwitchInventory 

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

ManageExpectedSwitchInventory is an activity wrapper for Expected Switch inventory collection and publishing

func NewManageExpectedSwitchInventory 

func NewManageExpectedSwitchInventory(siteID uuid.UUID, carbideAtomicClient *cclient.CarbideAtomicClient, temporalPublishClient tClient.Client, temporalPublishQueue string, cloudPageSize int) ManageExpectedSwitchInventory

NewManageExpectedSwitchInventory returns a ManageInventory implementation for Expected Switch activity

func (*ManageExpectedSwitchInventory) DiscoverExpectedSwitchInventory 

func (mesi *ManageExpectedSwitchInventory) DiscoverExpectedSwitchInventory(ctx context.Context) error

DiscoverExpectedSwitchInventory is an activity to collect Expected Switch inventory and publish to Temporal queue

type ManageInfiniBandPartition 

type ManageInfiniBandPartition struct {
	CarbideAtomicClient *client.CarbideAtomicClient
}

ManageInfiniBandPartition is an activity wrapper for InfiniBand Partition management

func NewManageInfiniBandPartition 

func NewManageInfiniBandPartition(carbideClient *client.CarbideAtomicClient) ManageInfiniBandPartition

NewManageInfiniBandPartition returns a new ManageInfiniBandPartition client

func (*ManageInfiniBandPartition) CreateInfiniBandPartitionOnSite 

func (mibp *ManageInfiniBandPartition) CreateInfiniBandPartitionOnSite(ctx context.Context, request *cwssaws.IBPartitionCreationRequest) error

Function to create InfiniBand Partition with Carbide

func (*ManageInfiniBandPartition) DeleteInfiniBandPartitionOnSite 

func (mipb *ManageInfiniBandPartition) DeleteInfiniBandPartitionOnSite(ctx context.Context, request *cwssaws.IBPartitionDeletionRequest) error

Function to delete InfiniBand Partition on Carbide

type ManageInfiniBandPartitionInventory 

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

ManageInfiniBandPartitionInventory is an activity wrapper for InfiniBand Partition inventory collection and publishing

func NewManageInfiniBandPartitionInventory 

func NewManageInfiniBandPartitionInventory(config ManageInventoryConfig) ManageInfiniBandPartitionInventory

NewManageInfiniBandPartitionInventory returns a ManageInventory implementation for InfiniBand Partition activity

func (*ManageInfiniBandPartitionInventory) DiscoverInfiniBandPartitionInventory 

func (mmi *ManageInfiniBandPartitionInventory) DiscoverInfiniBandPartitionInventory(ctx context.Context) error

DiscoverInfiniBandPartitionInventory is an activity to collect InfiniBand Partition inventory and publish to Temporal queue

type ManageInstance 

type ManageInstance struct {
	CarbideAtomicClient *cClient.CarbideAtomicClient
}

ManageInstance is an activity wrapper for Instance management tasks that allows injecting DB access

func NewManageInstance 

func NewManageInstance(carbideClient *cClient.CarbideAtomicClient) ManageInstance

NewManageInstance returns a new ManageInstance activity

func (*ManageInstance) CreateInstanceOnSite 

func (mm *ManageInstance) CreateInstanceOnSite(ctx context.Context, request *cwssaws.InstanceAllocationRequest) error

Function to Create (allocate) Forge Instance with the Site Controller

func (*ManageInstance) CreateInstancesOnSite 

func (mm *ManageInstance) CreateInstancesOnSite(ctx context.Context, request *cwssaws.BatchInstanceAllocationRequest) error

CreateInstancesOnSite is an activity to create (allocate) multiple Forge Instances with the Site Controller in a single transaction. This is the batch version of CreateInstanceOnSite.

func (*ManageInstance) DeleteInstanceOnSite 

func (mm *ManageInstance) DeleteInstanceOnSite(ctx context.Context, request *cwssaws.InstanceReleaseRequest) error

Function to Delete Forge Instance with the Site Controller

func (*ManageInstance) RebootInstanceOnSite 

func (mm *ManageInstance) RebootInstanceOnSite(ctx context.Context, request *cwssaws.InstancePowerRequest) error

Function to Create (allocate) Forge Instance with the Site Controller

func (*ManageInstance) UpdateInstanceOnSite 

func (mm *ManageInstance) UpdateInstanceOnSite(ctx context.Context, request *cwssaws.InstanceConfigUpdateRequest) error

Function Update Forge Instance with the Site Controller

type ManageInstanceInventory 

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

ManageInstanceInventory is an activity wrapper for Instance inventory collection and publishing

func NewManageInstanceInventory 

func NewManageInstanceInventory(config ManageInventoryConfig) ManageInstanceInventory

NewManageInstanceInventory returns a ManageInventory implementation for Instance activity

func (*ManageInstanceInventory) DiscoverInstanceInventory 

func (mmi *ManageInstanceInventory) DiscoverInstanceInventory(ctx context.Context) error

DiscoverInstanceInventory is an activity to collect Instance inventory and publish to Temporal queue

type ManageInstanceType 

type ManageInstanceType struct {
	CarbideAtomicClient *cClient.CarbideAtomicClient
}

ManageInstanceType is an activity wrapper for InstanceType management tasks that allows injecting DB access

func NewManageInstanceType 

func NewManageInstanceType(carbideClient *cClient.CarbideAtomicClient) ManageInstanceType

NewManageInstanceType returns a new ManageInstanceType activity

func (*ManageInstanceType) AssociateMachinesWithInstanceTypeOnSite 

func (mm *ManageInstanceType) AssociateMachinesWithInstanceTypeOnSite(ctx context.Context, request *cwssaws.AssociateMachinesWithInstanceTypeRequest) error

Function to associate Machine records with an InstanceType

func (*ManageInstanceType) CreateInstanceTypeOnSite 

func (mm *ManageInstanceType) CreateInstanceTypeOnSite(ctx context.Context, request *cwssaws.CreateInstanceTypeRequest) error

Function to Create Forge InstanceType with the Site Controller

func (*ManageInstanceType) DeleteInstanceTypeOnSite 

func (mm *ManageInstanceType) DeleteInstanceTypeOnSite(ctx context.Context, request *cwssaws.DeleteInstanceTypeRequest) error

Function to Delete Forge InstanceType with the Site Controller

func (*ManageInstanceType) RemoveMachineInstanceTypeAssociationOnSite 

func (mm *ManageInstanceType) RemoveMachineInstanceTypeAssociationOnSite(ctx context.Context, request *cwssaws.RemoveMachineInstanceTypeAssociationRequest) error

Function to remove the association between a Machine and InstanceType

func (*ManageInstanceType) UpdateInstanceTypeOnSite 

func (mm *ManageInstanceType) UpdateInstanceTypeOnSite(ctx context.Context, request *cwssaws.UpdateInstanceTypeRequest) error

Function Update Forge InstanceType with the Site Controller

type ManageInstanceTypeInventory 

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

ManageInstanceTypeInventory is an activity wrapper for InstanceType inventory collection and publishing

func NewManageInstanceTypeInventory 

func NewManageInstanceTypeInventory(config ManageInventoryConfig) ManageInstanceTypeInventory

NewManageInstanceTypeInventory returns a ManageInventory implementation for InstanceType activity

func (*ManageInstanceTypeInventory) DiscoverInstanceTypeInventory 

func (mmi *ManageInstanceTypeInventory) DiscoverInstanceTypeInventory(ctx context.Context) error

DiscoverInstanceTypeInventory is an activity to collect InstanceType inventory and publish to Temporal queue

type ManageInventoryConfig 

type ManageInventoryConfig struct {
	SiteID                uuid.UUID
	CarbideAtomicClient   *cClient.CarbideAtomicClient
	TemporalPublishClient tClient.Client
	TemporalPublishQueue  string
	SitePageSize          int
	CloudPageSize         int
}

type ManageMachine 

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

ManageMachine is an activity wrapper for Machine management tasks that allows injecting DB access

func NewManageMachine 

func NewManageMachine(carbideAtomicClient *cClient.CarbideAtomicClient) ManageMachine

NewManageMachine returns a new ManageMachine activity

func (*ManageMachine) GetDpuMachinesByIDs 

func (mm *ManageMachine) GetDpuMachinesByIDs(ctx context.Context, dpuMachineIDs []string) ([]*cwssaws.DpuMachine, error)

GetDpuMachinesByIDs is an activity to retrieve DPU Machines by IDs with network configuration

func (*ManageMachine) SetMachineMaintenanceOnSite 

func (mm *ManageMachine) SetMachineMaintenanceOnSite(ctx context.Context, request *cwssaws.MaintenanceRequest) error

SetMachineMaintenanceOnSite is an activity to set Machine maintenance mode using Site Controller API

func (*ManageMachine) UpdateMachineMetadataOnSite 

func (mm *ManageMachine) UpdateMachineMetadataOnSite(ctx context.Context, request *cwssaws.MachineMetadataUpdateRequest) error

UpdateMachineMetadataOnSite is an activity to update Machine metadata using Site Controller API

type ManageMachineInventory 

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

ManageMachineInventory is an activity wrapper for Machine inventory collection and publishing

func NewManageMachineInventory 

func NewManageMachineInventory(siteID uuid.UUID, carbideAtomicClient *cClient.CarbideAtomicClient, temporalPublishClient tClient.Client, temporalPublishQueue string, sitePageSize int, cloudPageSize int) ManageMachineInventory

NewManageMachineInventory returns a new ManageMachineInventory activity

func (*ManageMachineInventory) CollectAndPublishMachineInventory 

func (mmi *ManageMachineInventory) CollectAndPublishMachineInventory(ctx context.Context) error

CollectAndPublishMachineInventory is an activity to collect Machine inventory and publish to Temporal queue

type ManageMachineValidation 

type ManageMachineValidation struct {
	CarbideAtomicClient *client.CarbideAtomicClient
}

ManageMachineValidation is an activity wrapper for Machine Validation management

func NewManageMachineValidation 

func NewManageMachineValidation(carbideClient *client.CarbideAtomicClient) ManageMachineValidation

NewManageMachineValidation returns a new ManageMachineValidation client

func (*ManageMachineValidation) AddMachineValidationTestOnSite 

func (mmv *ManageMachineValidation) AddMachineValidationTestOnSite(ctx context.Context, request *cwssaws.MachineValidationTestAddRequest) (*cwssaws.MachineValidationTestAddUpdateResponse, error)

func (*ManageMachineValidation) AddUpdateMachineValidationExternalConfigOnSite 

func (mmv *ManageMachineValidation) AddUpdateMachineValidationExternalConfigOnSite(ctx context.Context, request *cwssaws.AddUpdateMachineValidationExternalConfigRequest) error

func (*ManageMachineValidation) EnableDisableMachineValidationTestOnSite 

func (mmv *ManageMachineValidation) EnableDisableMachineValidationTestOnSite(ctx context.Context, request *cwssaws.MachineValidationTestEnableDisableTestRequest) error

func (*ManageMachineValidation) GetMachineValidationExternalConfigsFromSite 

func (mmv *ManageMachineValidation) GetMachineValidationExternalConfigsFromSite(ctx context.Context, request *cwssaws.GetMachineValidationExternalConfigsRequest) (*cwssaws.GetMachineValidationExternalConfigsResponse, error)

func (*ManageMachineValidation) GetMachineValidationResultsFromSite 

func (mmv *ManageMachineValidation) GetMachineValidationResultsFromSite(ctx context.Context, request *cwssaws.MachineValidationGetRequest) (*cwssaws.MachineValidationResultList, error)

func (*ManageMachineValidation) GetMachineValidationRunsFromSite 

func (mmv *ManageMachineValidation) GetMachineValidationRunsFromSite(ctx context.Context, request *cwssaws.MachineValidationRunListGetRequest) (*cwssaws.MachineValidationRunList, error)

func (*ManageMachineValidation) GetMachineValidationTestsFromSite 

func (mmv *ManageMachineValidation) GetMachineValidationTestsFromSite(ctx context.Context, request *cwssaws.MachineValidationTestsGetRequest) (*cwssaws.MachineValidationTestsGetResponse, error)

func (*ManageMachineValidation) PersistValidationResultOnSite 

func (mmv *ManageMachineValidation) PersistValidationResultOnSite(ctx context.Context, request *cwssaws.MachineValidationResultPostRequest) error

func (*ManageMachineValidation) RemoveMachineValidationExternalConfigOnSite 

func (mmv *ManageMachineValidation) RemoveMachineValidationExternalConfigOnSite(ctx context.Context, request *cwssaws.RemoveMachineValidationExternalConfigRequest) error

func (*ManageMachineValidation) UpdateMachineValidationTestOnSite 

func (mmv *ManageMachineValidation) UpdateMachineValidationTestOnSite(ctx context.Context, request *cwssaws.MachineValidationTestUpdateRequest) error

type ManageNVLinkLogicalPartition 

type ManageNVLinkLogicalPartition struct {
	CarbideAtomicClient *cClient.CarbideAtomicClient
}

ManageNVLinkLogicalPartition is an activity wrapper for NVLinkLogical Partition management

func NewManageNVLinkLogicalPartition 

func NewManageNVLinkLogicalPartition(carbideClient *cClient.CarbideAtomicClient) ManageNVLinkLogicalPartition

NewManageNVLinkLogicalPartition returns a new ManageNVLinkLogicalPartition client

func (*ManageNVLinkLogicalPartition) CreateNVLinkLogicalPartitionOnSite 

func (mnvllp *ManageNVLinkLogicalPartition) CreateNVLinkLogicalPartitionOnSite(ctx context.Context, request *cwssaws.NVLinkLogicalPartitionCreationRequest) (*cwssaws.NVLinkLogicalPartition, error)

Function to create NVLinkLogical Partition with Carbide

func (*ManageNVLinkLogicalPartition) DeleteNVLinkLogicalPartitionOnSite 

func (mnvllp *ManageNVLinkLogicalPartition) DeleteNVLinkLogicalPartitionOnSite(ctx context.Context, request *cwssaws.NVLinkLogicalPartitionDeletionRequest) error

Function to delete NVLinkLogical Partition on Carbide

func (*ManageNVLinkLogicalPartition) UpdateNVLinkLogicalPartitionOnSite 

func (mnvllp *ManageNVLinkLogicalPartition) UpdateNVLinkLogicalPartitionOnSite(ctx context.Context, request *cwssaws.NVLinkLogicalPartitionUpdateRequest) error

Function to update NVLinkLogical Partition with Carbide

type ManageNVLinkLogicalPartitionInventory 

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

ManageNVLinkLogicalPartitionInventory is an activity wrapper for NVLinkLogical Partition inventory collection and publishing

func NewManageNVLinkLogicalPartitionInventory 

func NewManageNVLinkLogicalPartitionInventory(config ManageInventoryConfig) ManageNVLinkLogicalPartitionInventory

NewManageNVLinkLogicalPartitionInventory returns a ManageInventory implementation for NVLinkLogical Partition activity

func (*ManageNVLinkLogicalPartitionInventory) DiscoverNVLinkLogicalPartitionInventory 

func (mmi *ManageNVLinkLogicalPartitionInventory) DiscoverNVLinkLogicalPartitionInventory(ctx context.Context) error

DiscoverNVLinkLogicalPartitionInventory is an activity to collect NVLinkLogical Partition inventory and publish to Temporal queue

type ManageNetworkSecurityGroup 

type ManageNetworkSecurityGroup struct {
	CarbideAtomicClient *cClient.CarbideAtomicClient
}

ManageNetworkSecurityGroup is an activity wrapper for NetworkSecurityGroup management tasks that allows injecting DB access

func NewManageNetworkSecurityGroup 

func NewManageNetworkSecurityGroup(carbideClient *cClient.CarbideAtomicClient) ManageNetworkSecurityGroup

NewManageNetworkSecurityGroup returns a new ManageNetworkSecurityGroup activity

func (*ManageNetworkSecurityGroup) CreateNetworkSecurityGroupOnSite 

func (mm *ManageNetworkSecurityGroup) CreateNetworkSecurityGroupOnSite(ctx context.Context, request *cwssaws.CreateNetworkSecurityGroupRequest) error

Function to Create Forge NetworkSecurityGroup with the Site Controller

func (*ManageNetworkSecurityGroup) DeleteNetworkSecurityGroupOnSite 

func (mm *ManageNetworkSecurityGroup) DeleteNetworkSecurityGroupOnSite(ctx context.Context, request *cwssaws.DeleteNetworkSecurityGroupRequest) error

Function to Delete Forge NetworkSecurityGroup with the Site Controller

func (*ManageNetworkSecurityGroup) UpdateNetworkSecurityGroupOnSite 

func (mm *ManageNetworkSecurityGroup) UpdateNetworkSecurityGroupOnSite(ctx context.Context, request *cwssaws.UpdateNetworkSecurityGroupRequest) error

Function Update Forge NetworkSecurityGroup with the Site Controller

type ManageNetworkSecurityGroupInventory 

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

ManageNetworkSecurityGroupInventory is an activity wrapper for NetworkSecurityGroup inventory collection and publishing

func NewManageNetworkSecurityGroupInventory 

func NewManageNetworkSecurityGroupInventory(config ManageInventoryConfig) ManageNetworkSecurityGroupInventory

NewManageNetworkSecurityGroupInventory returns a ManageInventory implementation for NetworkSecurityGroup activity

func (*ManageNetworkSecurityGroupInventory) DiscoverNetworkSecurityGroupInventory 

func (mmi *ManageNetworkSecurityGroupInventory) DiscoverNetworkSecurityGroupInventory(ctx context.Context) error

DiscoverNetworkSecurityGroupInventory is an activity to collect NetworkSecurityGroup inventory and publish to Temporal queue

type ManageOperatingSystem 

type ManageOperatingSystem struct {
	CarbideAtomicClient *client.CarbideAtomicClient
}

ManageOperatingSystem is an activity wrapper for Operating System management

func NewManageOperatingSystem 

func NewManageOperatingSystem(carbideClient *client.CarbideAtomicClient) ManageOperatingSystem

NewManageOperatingSystem returns a new ManageOperatingSystem client

func (*ManageOperatingSystem) CreateOsImageOnSite 

func (mos *ManageOperatingSystem) CreateOsImageOnSite(ctx context.Context, request *cwssaws.OsImageAttributes) error

Function to create OsImage with Carbide

func (*ManageOperatingSystem) DeleteOsImageOnSite 

func (mos *ManageOperatingSystem) DeleteOsImageOnSite(ctx context.Context, request *cwssaws.DeleteOsImageRequest) error

Function to delete OsImage on Carbide

func (*ManageOperatingSystem) UpdateOsImageOnSite 

func (mos *ManageOperatingSystem) UpdateOsImageOnSite(ctx context.Context, request *cwssaws.OsImageAttributes) error

Function to update OsImage with Carbide

type ManageOsImageInventory 

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

ManageOsImageInventory is an activity wrapper for OS Image inventory collection and publishing

func NewManageOsImageInventory 

func NewManageOsImageInventory(config ManageInventoryConfig) ManageOsImageInventory

NewManageOsImageInventory returns a ManageInventory implementation for OS Image

func (*ManageOsImageInventory) DiscoverOsImageInventory 

func (moii *ManageOsImageInventory) DiscoverOsImageInventory(ctx context.Context) error

DiscoverOsImageInventory is an activity to collect OS Image inventory and publish to Temporal queue

type ManageRack 

type ManageRack struct {
	RlaAtomicClient *cClient.RlaAtomicClient
}

ManageRack is an activity wrapper for Rack management via RLA

func NewManageRack 

func NewManageRack(rlaClient *cClient.RlaAtomicClient) ManageRack

NewManageRack returns a new ManageRack client

func (*ManageRack) BringUpRack 

func (mr *ManageRack) BringUpRack(ctx context.Context, request *rlav1.BringUpRackRequest) (*rlav1.SubmitTaskResponse, error)

BringUpRack brings up a rack or its specified components via RLA

func (*ManageRack) GetRack 

func (mr *ManageRack) GetRack(ctx context.Context, request *rlav1.GetRackInfoByIDRequest) (*rlav1.GetRackInfoResponse, error)

GetRack retrieves a rack by its UUID from RLA

func (*ManageRack) GetRacks 

func (mr *ManageRack) GetRacks(ctx context.Context, request *rlav1.GetListOfRacksRequest) (*rlav1.GetListOfRacksResponse, error)

GetRacks retrieves a list of racks from RLA with optional filters

func (*ManageRack) PowerOffRack 

func (mr *ManageRack) PowerOffRack(ctx context.Context, request *rlav1.PowerOffRackRequest) (*rlav1.SubmitTaskResponse, error)

PowerOffRack powers off a rack or its specified components via RLA

func (*ManageRack) PowerOnRack 

func (mr *ManageRack) PowerOnRack(ctx context.Context, request *rlav1.PowerOnRackRequest) (*rlav1.SubmitTaskResponse, error)

PowerOnRack powers on a rack or its specified components via RLA

func (*ManageRack) PowerResetRack 

func (mr *ManageRack) PowerResetRack(ctx context.Context, request *rlav1.PowerResetRackRequest) (*rlav1.SubmitTaskResponse, error)

PowerResetRack resets (power cycles) a rack or its specified components via RLA

func (*ManageRack) UpgradeFirmware 

func (mr *ManageRack) UpgradeFirmware(ctx context.Context, request *rlav1.UpgradeFirmwareRequest) (*rlav1.SubmitTaskResponse, error)

UpgradeFirmware upgrades firmware on racks or components via RLA

func (*ManageRack) ValidateRackComponents 

func (mr *ManageRack) ValidateRackComponents(ctx context.Context, request *rlav1.ValidateComponentsRequest) (*rlav1.ValidateComponentsResponse, error)

ValidateRackComponents validates rack components by comparing expected vs actual state via RLA. Supports validating a single rack, multiple racks with filters, or all racks in a site.

type ManageSSHKeyGroup 

type ManageSSHKeyGroup struct {
	CarbideAtomicClient *client.CarbideAtomicClient
}

ManageSSHKeyGroup is an activity wrapper for SSHKeyGroup management

func NewManageSSHKeyGroup 

func NewManageSSHKeyGroup(carbideClient *client.CarbideAtomicClient) ManageSSHKeyGroup

NewManageSSHKeyGroup returns a new ManageSSHKeyGroup client

func (*ManageSSHKeyGroup) CreateSSHKeyGroupOnSite 

func (mmi *ManageSSHKeyGroup) CreateSSHKeyGroupOnSite(ctx context.Context, request *cwssaws.CreateTenantKeysetRequest) error

Function to create SSH Key Group with Carbide

func (*ManageSSHKeyGroup) DeleteSSHKeyGroupOnSite 

func (mmi *ManageSSHKeyGroup) DeleteSSHKeyGroupOnSite(ctx context.Context, request *cwssaws.DeleteTenantKeysetRequest) error

Function to Delete SSH Key Group with Carbide

func (*ManageSSHKeyGroup) UpdateSSHKeyGroupOnSite 

func (mmi *ManageSSHKeyGroup) UpdateSSHKeyGroupOnSite(ctx context.Context, request *cwssaws.UpdateTenantKeysetRequest) error

Function to Update SSH Key Group with Carbide

type ManageSSHKeyGroupInventory 

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

ManageSSHKeyGroupInventory is an activity wrapper for SSHKeyGroup inventory collection and publishing

func NewManageSSHKeyGroupInventory 

func NewManageSSHKeyGroupInventory(config ManageInventoryConfig) ManageSSHKeyGroupInventory

NewManageSSHKeyGroupInventory returns a ManageInventory implementation for SSHKeyGroup activity

func (*ManageSSHKeyGroupInventory) DiscoverSSHKeyGroupInventory 

func (mmi *ManageSSHKeyGroupInventory) DiscoverSSHKeyGroupInventory(ctx context.Context) error

DiscoverSSHKeyGroupInventory is an activity to collect SSHKeyGroup inventory and publish to Temporal queue

type ManageSkuInventory 

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

ManageSkuInventory is an activity wrapper for Sku inventory collection and publishing

func NewManageSkuInventory 

func NewManageSkuInventory(config ManageInventoryConfig) ManageSkuInventory

NewManageSkuInventory returns a ManageInventory implementation for Sku activity

func (*ManageSkuInventory) DiscoverSkuInventory 

func (msi *ManageSkuInventory) DiscoverSkuInventory(ctx context.Context) error

DiscoverSkuInventory is an activity to collect Sku inventory and publish to Temporal queue

type ManageSubnet 

type ManageSubnet struct {
	CarbideAtomicClient *cClient.CarbideAtomicClient
}

ManageSubnet is an activity wrapper for Subnet management tasks that allows injecting DB access

func NewManageSubnet 

func NewManageSubnet(carbideClient *cClient.CarbideAtomicClient) ManageSubnet

NewManageSubnet returns a new ManageSubnet client

func (*ManageSubnet) CreateSubnetOnSite 

func (mm *ManageSubnet) CreateSubnetOnSite(ctx context.Context, request *cwssaws.NetworkSegmentCreationRequest) error

Function to Create Subnets with the Site Controller

func (*ManageSubnet) DeleteSubnetOnSite 

func (mm *ManageSubnet) DeleteSubnetOnSite(ctx context.Context, request *cwssaws.NetworkSegmentDeletionRequest) error

Function to Delete Subnets with the Site Controller

type ManageSubnetInventory 

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

ManageSubnetInventory is an activity wrapper for Subnet inventory collection and publishing

func NewManageSubnetInventory 

func NewManageSubnetInventory(config ManageInventoryConfig) ManageSubnetInventory

NewManageSubnetInventory returns a ManageInventory implementation for Subnet activity

func (*ManageSubnetInventory) DiscoverSubnetInventory 

func (mmi *ManageSubnetInventory) DiscoverSubnetInventory(ctx context.Context) error

DiscoverSubnetInventory is an activity to collect Subnet inventory and publish to Temporal queue

type ManageTenant 

type ManageTenant struct {
	CarbideAtomicClient *cClient.CarbideAtomicClient
}

ManageTenant is activity to manage a Tenant on Site

func NewManageTenant 

func NewManageTenant(carbideClient *cClient.CarbideAtomicClient) ManageTenant

NewManageTenant returns a new ManageTenant activity

func (*ManageTenant) CreateTenantOnSite 

func (mt *ManageTenant) CreateTenantOnSite(ctx context.Context, request *cwssaws.CreateTenantRequest) error

CreateTenantOnSite creates a Tenant by calling Site Controller gRPC API

func (*ManageTenant) UpdateTenantOnSite 

func (mt *ManageTenant) UpdateTenantOnSite(ctx context.Context, request *cwssaws.UpdateTenantRequest) error

UpdateTenantOnSite creates a Tenant by calling Site Controller gRPC API

type ManageTenantInventory 

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

ManageTenantInventory is an activity wrapper for VPC inventory collection and publishing

func NewManageTenantInventory 

func NewManageTenantInventory(config ManageInventoryConfig) ManageTenantInventory

NewManageTenantInventory returns a ManageInventory implementation for VPC activity

func (*ManageTenantInventory) DiscoverTenantInventory 

func (mti *ManageTenantInventory) DiscoverTenantInventory(ctx context.Context) error

ManageTenantInventory is an activity to collect Tenant inventory and publish to Cloud

type ManageTray 

type ManageTray struct {
	RlaAtomicClient *cClient.RlaAtomicClient
}

ManageTray is an activity wrapper for Tray management via RLA

func NewManageTray 

func NewManageTray(rlaClient *cClient.RlaAtomicClient) ManageTray

NewManageTray returns a new ManageTray client

func (*ManageTray) GetTray 

func (mt *ManageTray) GetTray(ctx context.Context, request *rlav1.GetComponentInfoByIDRequest) (*rlav1.GetComponentInfoResponse, error)

GetTray retrieves a tray by its UUID from RLA

func (*ManageTray) GetTrays 

func (mt *ManageTray) GetTrays(ctx context.Context, request *rlav1.GetComponentsRequest) (*rlav1.GetComponentsResponse, error)

GetTrays retrieves a list of trays from RLA with optional filters.

type ManageVPC 

type ManageVPC struct {
	CarbideAtomicClient *cClient.CarbideAtomicClient
}

ManageVPC is an activity wrapper for VPC management TODO: Do we really need a distinction between general management and inventory? The pattern is elsewhere as well, but it seems like we could condense them since Manage*Inventory.config has a property that holds a *client.CarbideAtomicClient.

func NewManageVPC 

func NewManageVPC(carbideClient *cClient.CarbideAtomicClient) ManageVPC

NewManageVPC returns a new ManageVPC client

func (*ManageVPC) CreateVpcOnSite 

func (mv *ManageVPC) CreateVpcOnSite(ctx context.Context, request *cwssaws.VpcCreationRequest) error

Function to create VPCS with Carbide

func (*ManageVPC) DeleteVpcOnSite 

func (mv *ManageVPC) DeleteVpcOnSite(ctx context.Context, request *cwssaws.VpcDeletionRequest) error

Function to delete VPCS with Carbide

func (*ManageVPC) UpdateVpcOnSite 

func (mv *ManageVPC) UpdateVpcOnSite(ctx context.Context, request *cwssaws.VpcUpdateRequest) error

Function to update VPCS with Carbide

func (*ManageVPC) UpdateVpcVirtualizationOnSite 

func (mv *ManageVPC) UpdateVpcVirtualizationOnSite(ctx context.Context, request *cwssaws.VpcUpdateVirtualizationRequest) error

UpdateVpcVirtualizationOnSite updates VPC virtualization on Site

type ManageVPCInventory 

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

ManageVPCInventory is an activity wrapper for VPC inventory collection and publishing

func NewManageVPCInventory 

func NewManageVPCInventory(config ManageInventoryConfig) ManageVPCInventory

NewManageVPCInventory returns a ManageInventory implementation for VPC activity

func (*ManageVPCInventory) DiscoverVPCInventory 

func (mvi *ManageVPCInventory) DiscoverVPCInventory(ctx context.Context) error

DiscoverVPCInventory is an activity to collect VPC inventory and publish to Temporal queue

type ManageVpcPeering 

type ManageVpcPeering struct {
	CarbideAtomicClient *cClient.CarbideAtomicClient
}

ManageVpcPeering is an activity wrapper for VpcPeering management

func NewManageVpcPeering 

func NewManageVpcPeering(carbideClient *cClient.CarbideAtomicClient) ManageVpcPeering

NewManageVpcPeering returns a new ManageVpcPeering client

func (*ManageVpcPeering) CreateVpcPeeringOnSite 

func (mvp *ManageVpcPeering) CreateVpcPeeringOnSite(ctx context.Context, request *cwssaws.VpcPeeringCreationRequest) error

Function to create VpcPeering with Carbide

func (*ManageVpcPeering) DeleteVpcPeeringOnSite 

func (mvp *ManageVpcPeering) DeleteVpcPeeringOnSite(ctx context.Context, request *cwssaws.VpcPeeringDeletionRequest) error

Function to delete VpcPeering on Carbide

type ManageVpcPeeringInventory 

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

ManageVpcPeeringInventory is an activity wrapper for VpcPeering inventory collection and publishing

func NewManageVpcPeeringInventory 

func NewManageVpcPeeringInventory(config ManageInventoryConfig) ManageVpcPeeringInventory

func (*ManageVpcPeeringInventory) DiscoverVpcPeeringInventory 

func (mvi *ManageVpcPeeringInventory) DiscoverVpcPeeringInventory(ctx context.Context) error

DiscoverVpcPeeringInventory is an activity to collect VpcPeering inventory and publish to Temporal queue

type ManageVpcPrefix 

type ManageVpcPrefix struct {
	CarbideAtomicClient *client.CarbideAtomicClient
}

ManageVpcPrefix is an activity wrapper for VpcPrefix management

func NewManageVpcPrefix 

func NewManageVpcPrefix(carbideClient *client.CarbideAtomicClient) ManageVpcPrefix

NewManageVpcPrefix returns a new ManageVpcPrefix client

func (*ManageVpcPrefix) CreateVpcPrefixOnSite 

func (mvp *ManageVpcPrefix) CreateVpcPrefixOnSite(ctx context.Context, request *cwssaws.VpcPrefixCreationRequest) error

Function to create VpcPrefix with Carbide

func (*ManageVpcPrefix) DeleteVpcPrefixOnSite 

func (mvp *ManageVpcPrefix) DeleteVpcPrefixOnSite(ctx context.Context, request *cwssaws.VpcPrefixDeletionRequest) error

Function to delete VpcPrefix on Carbide

func (*ManageVpcPrefix) UpdateVpcPrefixOnSite 

func (mvp *ManageVpcPrefix) UpdateVpcPrefixOnSite(ctx context.Context, request *cwssaws.VpcPrefixUpdateRequest) error

Function to update VpcPrefix with Carbide

type ManageVpcPrefixInventory 

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

ManageVpcPrefixInventory is an activity wrapper for VpcPrefix inventory collection and publishing

func NewManageVpcPrefixInventory 

func NewManageVpcPrefixInventory(config ManageInventoryConfig) ManageVpcPrefixInventory

NewManageVpcPrefixInventory returns a ManageInventory implementation for VpcPrefix

func (*ManageVpcPrefixInventory) DiscoverVpcPrefixInventory 

func (moii *ManageVpcPrefixInventory) DiscoverVpcPrefixInventory(ctx context.Context) error

DiscoverVpcPrefixInventory is an activity to collect VpcPrefix inventory and publish to Temporal queue

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.