managerapi

type BootstrapExpansion interface{}

type BootstrapInterface interface {
	// List all the apis of Bootstrap here
	Init()
	Start()
	DownloadAndStoreCreds(otpOverride []byte) error
	GetState() []string

	BootstrapExpansion

	// Temporal Workflows - Subscriber
	RegisterSubscriber() error
}

type CarbideExpansion interface{}

type CarbideInterface interface {
	// List all the apis of Carbide here
	Init()
	Start()
	CreateGRPCClient() error
	GetGRPCClient() *client.CarbideClient
	UpdateGRPCClientState(err error)
	CreateGRPCClientActivity(ctx context.Context, ResourceID string) (client *client.CarbideClient, err error)
	RegisterGRPC()
	GetState() []string
	GetGRPCClientVersion() int64
	CarbideExpansion
}

type DpuExtensionServiceExpansion interface{}

type DpuExtensionServiceInterface interface {
	// List all the APIs for DPU Extension Service here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	GetState() []string
	DpuExtensionServiceExpansion
}

type ExpectedMachineExpansion interface{}

type ExpectedMachineInterface interface {
	// List all the apis of ExpectedMachine here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	GetState() []string
	ExpectedMachineExpansion
}

type ExpectedPowerShelfExpansion interface{}

type ExpectedPowerShelfInterface interface {
	// List all the apis of ExpectedPowerShelf here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	GetState() []string
	ExpectedPowerShelfExpansion
}

type ExpectedSwitchExpansion interface{}

type ExpectedSwitchInterface interface {
	// List all the apis of ExpectedSwitch here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	GetState() []string
	ExpectedSwitchExpansion
}

type HealthExpansion interface{}

type HealthInterface interface {
	// List all the apis of Health here
	Init()
	// RegisterSubscriber() error
	// RegisterPublisher() error
	HealthExpansion
}

type InfiniBandPartitionExpansion interface{}

type InfiniBandPartitionInterface interface {
	// List all the apis of InfiniBandPartition here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	// Cloud Workflow APIs
	CreateInfiniBandPartition(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.CreateInfiniBandPartitionRequest) (err error)
	DeleteInfiniBandPartition(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.DeleteInfiniBandPartitionRequest) (err error)

	// CreateInfiniBandPartition
	// RegisterWorkflows() error
	// RegisterActivities() error
	GetState() []string
	InfiniBandPartitionExpansion
}

type InstanceExpansion interface{}

type InstanceInterface interface {
	// List all the apis of Instance here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	// Temporal Workflows - Subscriber
	//Create Instance (deprecated)
	CreateInstance(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.CreateInstanceRequest) (err error)
	//Delete Instance (deprecated)
	DeleteInstance(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.DeleteInstanceRequest) (err error)
	//RebootInstance (deprecated)
	RebootInstance(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.RebootInstanceRequest) (err error)
	GetState() []string

	InstanceExpansion
}

type InstanceTypeExpansion interface{}

type InstanceTypeInterface interface {
	// List all the APIs for InstanceType here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	GetState() []string
	InstanceTypeExpansion
}

type MachineExpansion interface{}

type MachineInterface interface {
	// List all the apis of Machine here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error

	GetState() []string

	MachineExpansion
}

type MachineValidationExpansion interface{}

type MachineValidationInterface interface {
	// List all the APIs for MachineValidation here
	Init()
	RegisterSubscriber() error
	GetState() []string
	MachineValidationExpansion
}

type ManagerAPI struct {
	// Add all the manager interfaces here
	Bootstrap              BootstrapInterface
	VPC                    VPCInterface
	VpcPrefix              VpcPrefixInterface
	Subnet                 SubnetInterface
	Instance               InstanceInterface
	Machine                MachineInterface
	Orchestrator           OrchestratorInterface
	Carbide                CarbideInterface
	Health                 HealthInterface
	SSHKeyGroup            SSHKeyGroupInterface
	InfiniBandPartition    InfiniBandPartitionInterface
	Tenant                 TenantInterface
	OperatingSystem        OperatingSystemInterface
	MachineValidation      MachineValidationInterface
	InstanceType           InstanceTypeInterface
	NetworkSecurityGroup   NetworkSecurityGroupInterface
	ExpectedMachine        ExpectedMachineInterface
	ExpectedPowerShelf     ExpectedPowerShelfInterface
	ExpectedSwitch         ExpectedSwitchInterface
	SKU                    SKUInterface
	DpuExtensionService    DpuExtensionServiceInterface
	NVLinkLogicalPartition NVLinkLogicalPartitionInterface
	RLA                    RLAInterface
}

type ManagerAccess struct {
	API  *ManagerAPI
	Data *ManagerData
	Conf *ManagerConf
}

type ManagerConf struct {
	EB *conftypes.Config
}

type ManagerData struct {
	EB *elektratypes.Elektra
}

type NVLinkLogicalPartitionExpansion interface{}

type NVLinkLogicalPartitionInterface interface {
	// List all the apis of NVLinkLogicalPartition here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	GetState() []string
	NVLinkLogicalPartitionExpansion
}

type NetworkSecurityGroupExpansion interface{}

type NetworkSecurityGroupInterface interface {
	// List all the APIs for NetworkSecurityGroup here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	GetState() []string
	NetworkSecurityGroupExpansion
}

type OperatingSystemExpansion interface{}

type OperatingSystemInterface interface {
	// List all the APIs for Operating System here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	GetState() []string
	OperatingSystemExpansion
}

type OrchestratorExpansion interface{}

type OrchestratorInterface interface {
	// List all the apis of Orchestrator here
	Init()
	Start()
	GetState() []string
	AddWorkflow(wflow interface{})
	DoWorkflow(ctx workflow.Context, TransactionID *wflows.TransactionID,
		ResourceRequest interface{}, wflowMd wflowtypes.WorkflowMetadata,
		retryOptions *wflows.WorkflowOptions) (actErr error, pubErr error)
	DoActivity(ctx context.Context, ResourceVer uint64, ResourceID string,
		ResourceReq interface{}, wflowMd wflowtypes.WorkflowMetadata) (interface{}, error)

	OrchestratorExpansion
}

type RLAExpansion interface{}

type RLAInterface interface {
	// List all the apis of RLA here
	Init()
	Start()
	CreateGRPCClient() error
	GetGRPCClient() *client.RlaClient
	UpdateGRPCClientState(err error)
	CreateGRPCClientActivity(ctx context.Context, ResourceID string) (client *client.RlaClient, err error)
	RegisterGRPC()
	RegisterSubscriber() error
	GetState() []string
	GetGRPCClientVersion() int64
	RLAExpansion
}

type SKUExpansion interface{}

type SKUInterface interface {
	// List all the apis of SKU here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	GetState() []string
	SKUExpansion
}

type SSHKeyGroupExpansion interface{}

type SSHKeyGroupInterface interface {
	// List all the apis of SSHKeyGroup here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	// Cloud Workflow APIs
	CreateSSHKeyGroup(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.CreateSSHKeyGroupRequest) (err error)
	DeleteSSHKeyGroup(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.DeleteSSHKeyGroupRequest) (err error)

	// CRUD SSHKeyGroup APIs
	UpdateSSHKeyGroup(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.UpdateSSHKeyGroupRequest) (err error)
	// GetSSHKeyGroupByID(ctx workflow.Context, ResourceID string, SSHKeyGroupID string) (ResourceResponse *wflows.GetSSHKeyGroupResponse, err error)
	GetSSHKeyGroup(ctx workflow.Context, ResourceID string, ResourceRequest *wflows.GetSSHKeyGroup) (ResourceResponse *wflows.GetSSHKeyGroupResponse, err error)

	// CreateSSHKeyGroup
	// RegisterWorkflows() error
	// RegisterActivities() error
	GetState() []string
	SSHKeyGroupExpansion
}

type SubnetExpansion interface{}

type SubnetInterface interface {
	// List all the apis of Subnet here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	// Temporal Workflows - Subscriber
	CreateSubnet(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.CreateSubnetRequest) (err error)
	// Implement this when this is available in Site controller
	// UpdateSubnet(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.UpdateSubnetRequest) (err error)
	DeleteSubnet(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.DeleteSubnetRequest) (err error)
	GetState() []string
	SubnetExpansion
}

type TenantExpansion interface{}

type TenantInterface interface {
	// List all the APIs for Tenant here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	GetState() []string
	TenantExpansion
}

type VPCExpansion interface{}

type VPCInterface interface {
	// List all the apis of VPC here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	// Cloud Workflow APIs
	CreateVPC(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.CreateVPCRequest) (err error)
	DeleteVPC(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.DeleteVPCRequest) (err error)

	// CRUD VPC APIs
	UpdateVPC(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.UpdateVPCRequest) (err error)
	// GetVPCByID(ctx workflow.Context, ResourceID string, VPCID string) (ResourceResponse *wflows.GetVPCResponse, err error)
	GetVPCByName(ctx workflow.Context, ResourceID string, VPCName string) (ResourceResponse *wflows.GetVPCResponse, err error)

	// CreateVPC
	// RegisterWorkflows() error
	// RegisterActivities() error
	GetState() []string
	VPCExpansion
}

type VpcPrefixExpansion interface{}

type VpcPrefixInterface interface {
	// List all the APIs for VpcPrefix here
	Init()
	RegisterSubscriber() error
	RegisterPublisher() error
	RegisterCron() error

	GetState() []string
	VpcPrefixExpansion
}