activity

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: 21 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, nicoClient *cClient.NICoCoreClient, ids []*cwssaws.VpcPeeringId) ([]*cwssaws.VpcPeering, error)

func VpcPeeringFindIDs 

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

func VpcPeeringPagedInventory 

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

func VpcPrefixFindByIDs 

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

func VpcPrefixFindFallback 

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

func VpcPrefixFindIDs 

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

func VpcPrefixPagedInventory 

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

Types

type ManageDpuExtensionService 

type ManageDpuExtensionService struct {
	NICoCoreAtomicClient *cclient.NICoCoreAtomicClient
}

ManageDpuExtensionService is an activity wrapper for DPU Extension Service management

func NewManageDpuExtensionService 

func NewManageDpuExtensionService(nicoClient *cclient.NICoCoreAtomicClient) 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 {
	NICoCoreAtomicClient *cclient.NICoCoreAtomicClient
	FlowAtomicClient     *cclient.FlowAtomicClient
}

ManageExpectedMachine is an activity wrapper for Expected Machine management

func NewManageExpectedMachine 

func NewManageExpectedMachine(nicoClient *cclient.NICoCoreAtomicClient, flowClient *cclient.FlowAtomicClient) ManageExpectedMachine

NewManageExpectedMachine returns a new ManageExpectedMachine client

func (*ManageExpectedMachine) CreateExpectedMachineOnFlow 

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

CreateExpectedMachineOnFlow creates an Expected Machine as a component in Flow via AddComponent

func (*ManageExpectedMachine) CreateExpectedMachineOnSite 

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

CreateExpectedMachineOnSite creates Expected Machine with NICo

func (*ManageExpectedMachine) CreateExpectedMachinesOnFlow 

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

CreateExpectedMachinesOnFlow creates multiple Expected Machines as components in Flow via AddComponent

func (*ManageExpectedMachine) CreateExpectedMachinesOnSite 

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

CreateExpectedMachinesOnSite creates multiple Expected Machines with NICo using the nico batch endpoint

func (*ManageExpectedMachine) DeleteExpectedMachineOnSite 

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

DeleteExpectedMachineOnSite deletes Expected Machine on NICo

func (*ManageExpectedMachine) UpdateExpectedMachineOnSite 

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

UpdateExpectedMachineOnSite updates Expected Machine on NICo

func (*ManageExpectedMachine) UpdateExpectedMachinesOnSite 

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

UpdateExpectedMachinesOnSite updates multiple Expected Machines on NICo 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, nicoCoreAtomicClient *cclient.NICoCoreAtomicClient, 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 {
	NICoCoreAtomicClient *cclient.NICoCoreAtomicClient
	FlowAtomicClient     *cclient.FlowAtomicClient
}

ManageExpectedPowerShelf is an activity wrapper for Expected Power Shelf management

func NewManageExpectedPowerShelf 

func NewManageExpectedPowerShelf(nicoClient *cclient.NICoCoreAtomicClient, flowClient *cclient.FlowAtomicClient) ManageExpectedPowerShelf

NewManageExpectedPowerShelf returns a new ManageExpectedPowerShelf client

func (*ManageExpectedPowerShelf) CreateExpectedPowerShelfOnFlow 

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

CreateExpectedPowerShelfOnFlow creates an Expected Power Shelf as a component in Flow via AddComponent

func (*ManageExpectedPowerShelf) CreateExpectedPowerShelfOnSite 

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

CreateExpectedPowerShelfOnSite creates Expected Power Shelf with NICo

func (*ManageExpectedPowerShelf) DeleteExpectedPowerShelfOnSite 

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

DeleteExpectedPowerShelfOnSite deletes Expected Power Shelf on NICo

func (*ManageExpectedPowerShelf) UpdateExpectedPowerShelfOnSite 

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

UpdateExpectedPowerShelfOnSite updates Expected Power Shelf on NICo

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, nicoCoreAtomicClient *cclient.NICoCoreAtomicClient, 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 ManageExpectedRack 

type ManageExpectedRack struct {
	NICoCoreAtomicClient *cclient.NICoCoreAtomicClient
	FlowAtomicClient     *cclient.FlowAtomicClient
}

ManageExpectedRack is an activity wrapper for Expected Rack management

func NewManageExpectedRack 

func NewManageExpectedRack(nicoClient *cclient.NICoCoreAtomicClient, flowClient *cclient.FlowAtomicClient) ManageExpectedRack

NewManageExpectedRack returns a new ManageExpectedRack client

func (*ManageExpectedRack) CreateExpectedRackOnFlow 

func (mer *ManageExpectedRack) CreateExpectedRackOnFlow(ctx context.Context, request *cwssaws.ExpectedRack) error

CreateExpectedRackOnFlow creates an Expected Rack in Flow via CreateExpectedRack. Best-effort: if the Flow client is not configured, the activity logs and returns nil so the workflow can continue. RPC failures are surfaced as errors so the workflow can decide how to handle them (typically log and ignore).

func (*ManageExpectedRack) CreateExpectedRackOnSite 

func (mer *ManageExpectedRack) CreateExpectedRackOnSite(ctx context.Context, request *cwssaws.ExpectedRack) error

CreateExpectedRackOnSite creates Expected Rack with NICo

func (*ManageExpectedRack) DeleteAllExpectedRacksOnSite 

func (mer *ManageExpectedRack) DeleteAllExpectedRacksOnSite(ctx context.Context) error

DeleteAllExpectedRacksOnSite deletes all Expected Racks on NICo

func (*ManageExpectedRack) DeleteExpectedRackOnSite 

func (mer *ManageExpectedRack) DeleteExpectedRackOnSite(ctx context.Context, request *cwssaws.ExpectedRackRequest) error

DeleteExpectedRackOnSite deletes Expected Rack on NICo

func (*ManageExpectedRack) ReplaceAllExpectedRacksOnSite 

func (mer *ManageExpectedRack) ReplaceAllExpectedRacksOnSite(ctx context.Context, request *cwssaws.ExpectedRackList) error

ReplaceAllExpectedRacksOnSite replaces all Expected Racks on NICo with the supplied list

func (*ManageExpectedRack) UpdateExpectedRackOnSite 

func (mer *ManageExpectedRack) UpdateExpectedRackOnSite(ctx context.Context, request *cwssaws.ExpectedRack) error

UpdateExpectedRackOnSite updates Expected Rack on NICo

type ManageExpectedRackInventory 

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

ManageExpectedRackInventory is an activity wrapper for Expected Rack inventory collection and publishing

func NewManageExpectedRackInventory 

func NewManageExpectedRackInventory(siteID uuid.UUID, nicoCoreAtomicClient *cclient.NICoCoreAtomicClient, temporalPublishClient tClient.Client, temporalPublishQueue string, cloudPageSize int) ManageExpectedRackInventory

NewManageExpectedRackInventory returns a ManageInventory implementation for Expected Rack activity

func (*ManageExpectedRackInventory) DiscoverExpectedRackInventory 

func (meri *ManageExpectedRackInventory) DiscoverExpectedRackInventory(ctx context.Context) error

DiscoverExpectedRackInventory is an activity to collect Expected Rack inventory and publish to Temporal queue

type ManageExpectedSwitch 

type ManageExpectedSwitch struct {
	NICoCoreAtomicClient *cclient.NICoCoreAtomicClient
	FlowAtomicClient     *cclient.FlowAtomicClient
}

ManageExpectedSwitch is an activity wrapper for Expected Switch management

func NewManageExpectedSwitch 

func NewManageExpectedSwitch(nicoClient *cclient.NICoCoreAtomicClient, flowClient *cclient.FlowAtomicClient) ManageExpectedSwitch

NewManageExpectedSwitch returns a new ManageExpectedSwitch client

func (*ManageExpectedSwitch) CreateExpectedSwitchOnFlow 

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

CreateExpectedSwitchOnFlow creates an Expected Switch as a component in Flow via AddComponent

func (*ManageExpectedSwitch) CreateExpectedSwitchOnSite 

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

CreateExpectedSwitchOnSite creates Expected Switch with NICo

func (*ManageExpectedSwitch) DeleteExpectedSwitchOnSite 

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

DeleteExpectedSwitchOnSite deletes Expected Switch on NICo

func (*ManageExpectedSwitch) UpdateExpectedSwitchOnSite 

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

UpdateExpectedSwitchOnSite updates Expected Switch on NICo

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, nicoCoreAtomicClient *cclient.NICoCoreAtomicClient, 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 {
	NICoCoreAtomicClient *client.NICoCoreAtomicClient
}

ManageInfiniBandPartition is an activity wrapper for InfiniBand Partition management

func NewManageInfiniBandPartition 

func NewManageInfiniBandPartition(nicoClient *client.NICoCoreAtomicClient) 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 NICo

func (*ManageInfiniBandPartition) DeleteInfiniBandPartitionOnSite 

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

Function to delete InfiniBand Partition on NICo

func (*ManageInfiniBandPartition) UpdateInfiniBandPartitionOnSite 

func (mibp *ManageInfiniBandPartition) UpdateInfiniBandPartitionOnSite(ctx context.Context, request *cwssaws.IBPartitionUpdateRequest) error

UpdateInfiniBandPartitionOnSite applies an IB partition update on the site NICo controller

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 {
	NICoCoreAtomicClient *cClient.NICoCoreAtomicClient
}

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

func NewManageInstance 

func NewManageInstance(nicoClient *cClient.NICoCoreAtomicClient) 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) NICo 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 NICo 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 NICo Instance with the Site Controller

func (*ManageInstance) RebootInstanceOnSite 

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

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

func (*ManageInstance) UpdateInstanceOnSite 

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

Function Update NICo 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 {
	NICoCoreAtomicClient *cClient.NICoCoreAtomicClient
}

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

func NewManageInstanceType 

func NewManageInstanceType(nicoClient *cClient.NICoCoreAtomicClient) 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 NICo InstanceType with the Site Controller

func (*ManageInstanceType) DeleteInstanceTypeOnSite 

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

Function to Delete NICo 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 NICo 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
	NICoCoreAtomicClient  *cClient.NICoCoreAtomicClient
	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(nicoCoreAtomicClient *cClient.NICoCoreAtomicClient) 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, nicoCoreAtomicClient *cClient.NICoCoreAtomicClient, 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 {
	NICoCoreAtomicClient *client.NICoCoreAtomicClient
}

ManageMachineValidation is an activity wrapper for Machine Validation management

func NewManageMachineValidation 

func NewManageMachineValidation(nicoClient *client.NICoCoreAtomicClient) 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 {
	NICoCoreAtomicClient *cClient.NICoCoreAtomicClient
}

ManageNVLinkLogicalPartition is an activity wrapper for NVLinkLogical Partition management

func NewManageNVLinkLogicalPartition 

func NewManageNVLinkLogicalPartition(nicoClient *cClient.NICoCoreAtomicClient) 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 NICo

func (*ManageNVLinkLogicalPartition) DeleteNVLinkLogicalPartitionOnSite 

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

Function to delete NVLinkLogical Partition on NICo

func (*ManageNVLinkLogicalPartition) UpdateNVLinkLogicalPartitionOnSite 

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

Function to update NVLinkLogical Partition with NICo

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 {
	NICoCoreAtomicClient *cClient.NICoCoreAtomicClient
}

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

func NewManageNetworkSecurityGroup 

func NewManageNetworkSecurityGroup(nicoClient *cClient.NICoCoreAtomicClient) ManageNetworkSecurityGroup

NewManageNetworkSecurityGroup returns a new ManageNetworkSecurityGroup activity

func (*ManageNetworkSecurityGroup) CreateNetworkSecurityGroupOnSite 

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

Function to Create NICo NetworkSecurityGroup with the Site Controller

func (*ManageNetworkSecurityGroup) DeleteNetworkSecurityGroupOnSite 

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

Function to Delete NICo NetworkSecurityGroup with the Site Controller

func (*ManageNetworkSecurityGroup) UpdateNetworkSecurityGroupOnSite 

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

Function Update NICo 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 {
	NICoCoreAtomicClient *client.NICoCoreAtomicClient
}

ManageOperatingSystem is an activity wrapper for Operating System management

func NewManageOperatingSystem 

func NewManageOperatingSystem(nicoClient *client.NICoCoreAtomicClient) 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 NICo

func (*ManageOperatingSystem) DeleteOsImageOnSite 

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

Function to delete OsImage on NICo

func (*ManageOperatingSystem) UpdateOsImageOnSite 

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

Function to update OsImage with NICo

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 {
	FlowAtomicClient *cClient.FlowAtomicClient
}

ManageRack is an activity wrapper for Rack management via Flow

func NewManageRack 

func NewManageRack(flowClient *cClient.FlowAtomicClient) ManageRack

NewManageRack returns a new ManageRack client

func (*ManageRack) BringUpRack 

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

BringUpRack brings up a rack or its specified components via Flow

func (*ManageRack) CancelTask 

func (mr *ManageRack) CancelTask(ctx context.Context, request *flowv1.CancelTaskRequest) (*flowv1.CancelTaskResponse, error)

CancelTask cancels a task by its UUID via Flow.

Cancel is best-effort: Flow marks the task Terminated and terminates the underlying Temporal workflow if one was scheduled. Already-finished tasks (Succeeded/Failed) cannot be cancelled and the Flow call returns an error.

func (*ManageRack) GetRack 

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

GetRack retrieves a rack by its UUID from Flow

func (*ManageRack) GetRacks 

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

GetRacks retrieves a list of racks from Flow with optional filters

func (*ManageRack) GetTaskByID 

func (mr *ManageRack) GetTaskByID(ctx context.Context, request *flowv1.GetTasksByIDsRequest) (*flowv1.GetTasksByIDsResponse, error)

GetTaskByID retrieves a task by its UUID from Flow

func (*ManageRack) PowerOffRack 

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

PowerOffRack powers off a rack or its specified components via Flow

func (*ManageRack) PowerOnRack 

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

PowerOnRack powers on a rack or its specified components via Flow

func (*ManageRack) PowerResetRack 

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

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

func (*ManageRack) UpgradeFirmware 

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

UpgradeFirmware upgrades firmware on racks or components via Flow

func (*ManageRack) ValidateRackComponents 

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

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

type ManageSSHKeyGroup 

type ManageSSHKeyGroup struct {
	NICoCoreAtomicClient *client.NICoCoreAtomicClient
}

ManageSSHKeyGroup is an activity wrapper for SSHKeyGroup management

func NewManageSSHKeyGroup 

func NewManageSSHKeyGroup(nicoClient *client.NICoCoreAtomicClient) 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 NICo

func (*ManageSSHKeyGroup) DeleteSSHKeyGroupOnSite 

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

Function to Delete SSH Key Group with NICo

func (*ManageSSHKeyGroup) UpdateSSHKeyGroupOnSite 

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

Function to Update SSH Key Group with NICo

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 {
	NICoCoreAtomicClient *cClient.NICoCoreAtomicClient
}

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

func NewManageSubnet 

func NewManageSubnet(nicoClient *cClient.NICoCoreAtomicClient) 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 {
	NICoCoreAtomicClient *cClient.NICoCoreAtomicClient
}

ManageTenant is activity to manage a Tenant on Site

func NewManageTenant 

func NewManageTenant(nicoClient *cClient.NICoCoreAtomicClient) 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 {
	FlowAtomicClient *cClient.FlowAtomicClient
}

ManageTray is an activity wrapper for Tray management via Flow

func NewManageTray 

func NewManageTray(flowClient *cClient.FlowAtomicClient) ManageTray

NewManageTray returns a new ManageTray client

func (*ManageTray) GetTray 

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

GetTray retrieves a tray by its UUID from Flow

func (*ManageTray) GetTrays 

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

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

type ManageVPC 

type ManageVPC struct {
	NICoCoreAtomicClient *cClient.NICoCoreAtomicClient
}

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.NICoCoreAtomicClient.

func NewManageVPC 

func NewManageVPC(nicoClient *cClient.NICoCoreAtomicClient) ManageVPC

NewManageVPC returns a new ManageVPC client

func (*ManageVPC) CreateVpcOnSite 

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

Function to create VPCS with NICo

func (*ManageVPC) DeleteVpcOnSite 

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

Function to delete VPCS with NICo

func (*ManageVPC) UpdateVpcOnSite 

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

Function to update VPCS with NICo

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 {
	NICoCoreAtomicClient *cClient.NICoCoreAtomicClient
}

ManageVpcPeering is an activity wrapper for VpcPeering management

func NewManageVpcPeering 

func NewManageVpcPeering(nicoClient *cClient.NICoCoreAtomicClient) 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 NICo

func (*ManageVpcPeering) DeleteVpcPeeringOnSite 

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

Function to delete VpcPeering on NICo

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 {
	NICoCoreAtomicClient *client.NICoCoreAtomicClient
}

ManageVpcPrefix is an activity wrapper for VpcPrefix management

func NewManageVpcPrefix 

func NewManageVpcPrefix(nicoClient *client.NICoCoreAtomicClient) 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 NICo

func (*ManageVpcPrefix) DeleteVpcPrefixOnSite 

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

Function to delete VpcPrefix on NICo

func (*ManageVpcPrefix) UpdateVpcPrefixOnSite 

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

Function to update VpcPrefix with NICo

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.