instance

package

v1.1.0 Latest Latest Go to latest Published: Mar 17, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/NVIDIA/ncx-infra-controller-rest

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func RegisterSubscribers()
type API
- func NewInstanceManager(superForge *elektratypes.Elektra, superAPI *Manager.ManagerAPI, ...) *API
type Workflows
- func NewInstanceWorkflows(tmPublish client.Client, tmSubscribe client.Client, ...) Workflows

Constants ¶

View Source

const (
	// InventoryQueuePrefix is the prefix for the inventory temporal queue
	InventoryQueuePrefix = "inventory-"
	// InventoryCarbidePageSize is the number of items to be fetched from Carbide API at a time
	InventoryCarbidePageSize = 100
	// InventoryCloudPageSize is the number of items to be sent to Cloud at a time
	InventoryCloudPageSize = 25
	// InventoryDefaultSchedule is the default schedule for inventory discovery
	InventoryDefaultSchedule = "@every 3m"
)

Variables ¶

View Source

var (
	// ErrGRPCClientConnection - Err GRPC client Connection
	ErrGRPCClientConnection = errors.New("GRPC client connection error")
)

View Source

var ManagerAccess *Manager.ManagerAccess

ManagerAccess - access to all managers

Functions ¶

func RegisterSubscribers ¶

func RegisterSubscribers()

RegisterSubscribers - this is method 2 of registering the subscriber

Types ¶

type API ¶

type API struct{}

API - all API interface nolint

func NewInstanceManager ¶

func NewInstanceManager(superForge *elektratypes.Elektra, superAPI *Manager.ManagerAPI, superConf *Manager.ManagerConf) *API

NewInstanceManager - returns a new instance of helm manager

func (*API) CreateInstance ¶

func (instance *API) CreateInstance(ctx workflow.Context, transactionID *wflows.TransactionID, resourceRequest *wflows.CreateInstanceRequest) (err error)

CreateInstance - temporal create instance workflow

func (*API) DeleteInstance ¶

func (instance *API) DeleteInstance(ctx workflow.Context, transactionID *wflows.TransactionID, resourceRequest *wflows.DeleteInstanceRequest) error

DeleteInstance - temporal delete Instance workflow

func (*API) GetState ¶

func (Instance *API) GetState() []string

GetState Subnet

func (*API) Init ¶

func (Instance *API) Init()

Init Instance

func (*API) RebootInstance ¶

func (instance *API) RebootInstance(ctx workflow.Context, transactionID *wflows.TransactionID, resourceRequest *wflows.RebootInstanceRequest) error

RebootInstance - temporal reboot Instance workflow

func (*API) RegisterCron ¶

func (api *API) RegisterCron() error

RegisterCron - Register Cron

func (*API) RegisterPublisher ¶

func (api *API) RegisterPublisher() error

RegisterPublisher registers the InstanceWorkflows with the Temporal client

func (*API) RegisterSubscriber ¶

func (api *API) RegisterSubscriber() error

RegisterSubscriber registers the InstanceWorkflows with the Temporal client

type Workflows ¶

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

Workflows Temporal registration

func NewInstanceWorkflows ¶

func NewInstanceWorkflows(tmPublish client.Client, tmSubscribe client.Client, currentCFG *conftypes.Config) Workflows

NewInstanceWorkflows creates an instance for InstanceWorkflows

func (*Workflows) CreateInstanceActivity ¶

func (ac *Workflows) CreateInstanceActivity(ctx context.Context, resourceVer uint64, resourceID string, resourceReq *wflows.CreateInstanceRequest) (*wflows.InstanceInfo, error)

CreateInstanceActivity - temporal activity TODO: Remove (Deprecated)

func (*Workflows) DeleteInstanceActivity ¶

func (ac *Workflows) DeleteInstanceActivity(ctx context.Context, resourceVer uint64, resourceID string, resourceReq string) (*wflows.InstanceInfo, error)

DeleteInstanceActivity - temporal activity

func (*Workflows) PublishInstanceActivity ¶

func (ac *Workflows) PublishInstanceActivity(ctx context.Context, TransactionID *wflows.TransactionID, InstanceInfo *wflows.InstanceInfo) (workflowID string, err error)

PublishInstanceActivity - Publish Instance Activity

func (*Workflows) PublishInstancePowerStatus ¶

func (ac *Workflows) PublishInstancePowerStatus(ctx context.Context, TransactionID *wflows.TransactionID, InstanceInfo *wflows.InstanceRebootInfo) (workflowID string, err error)

PublishInstancePowerStatus - Publish Instance Power Status

func (*Workflows) RebootInstanceActivity ¶

func (ac *Workflows) RebootInstanceActivity(ctx context.Context, resourceVer uint64, resourceID string, resourceReq *wflows.RebootInstanceRequest) (*wflows.InstanceRebootInfo, error)

RebootInstanceActivity - temporal activity TODO: Remove (deprecated)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL