sshkeygroup

package

v1.1.0 Latest Latest Go to latest Published: Mar 17, 2026 License: Apache-2.0 Imports: 19 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 NewSSHKeyGroupManager(superForge *elektratypes.Elektra, superAPI *Manager.ManagerAPI, ...) *API
type Workflows
- func NewSSHKeyGroupWorkflows(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

func NewSSHKeyGroupManager ¶

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

NewSSHKeyGroupManager - returns a new instance of helm manager

func (*API) CreateSSHKeyGroup ¶

func (api *API) CreateSSHKeyGroup(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.CreateSSHKeyGroupRequest) (err error)

CreateSSHKeyGroup creates a new SSHKeyGroupWorkflow and publishes result to cloud

func (*API) DeleteSSHKeyGroup ¶

func (api *API) DeleteSSHKeyGroup(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.DeleteSSHKeyGroupRequest) (err error)

DeleteSSHKeyGroup deletes a SSHKeyGroup

func (*API) GetSSHKeyGroup ¶

func (api *API) GetSSHKeyGroup(ctx workflow.Context, ResourceID string, ResourceRequest *wflows.GetSSHKeyGroup) (ResourceResponse *wflows.GetSSHKeyGroupResponse, err error)

GetSSHKeyGroup - retrieve SSHKeyGroups

func (*API) GetState ¶

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

GetState - handle http request

func (*API) Init ¶

func (SSHKeyGroup *API) Init()

Init SSHKeyGroup

func (*API) RegisterCron ¶

func (api *API) RegisterCron() error

RegisterCron - Register Cron

func (*API) RegisterPublisher ¶

func (api *API) RegisterPublisher() error

RegisterPublisher registers the SSHKeyGroupWorkflows with the Temporal client

func (*API) RegisterSubscriber ¶

func (api *API) RegisterSubscriber() error

RegisterSubscriber registers the SSHKeyGroupWorkflows with the Temporal client

func (*API) UpdateSSHKeyGroup ¶

func (api *API) UpdateSSHKeyGroup(ctx workflow.Context, TransactionID *wflows.TransactionID, ResourceRequest *wflows.UpdateSSHKeyGroupRequest) (err error)

UpdateSSHKeyGroup updates a SSHKeyGroupWorkflow

type Workflows ¶

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

Workflows - Temporal registration

func NewSSHKeyGroupWorkflows ¶

func NewSSHKeyGroupWorkflows(TMPublish client.Client, TMSubscribe client.Client, CurrentCFG *conftypes.Config) Workflows

NewSSHKeyGroupWorkflows creates an instance for SSHKeyGroupWorkflows

func (*Workflows) CreateSSHKeyGroupActivity ¶

func (ac *Workflows) CreateSSHKeyGroupActivity(ctx context.Context, ResourceVer uint64, ResourceID string,
	ResourceReq *wflows.CreateSSHKeyGroupRequest) (*wflows.SSHKeyGroupInfo, error)

CreateSSHKeyGroupActivity - Create SSHKeyGroup Activity

func (*Workflows) DeleteSSHKeyGroupActivity ¶

func (ac *Workflows) DeleteSSHKeyGroupActivity(ctx context.Context, ResourceVer uint64, ResourceID string,
	ResourceReq *wflows.DeleteSSHKeyGroupRequest) (*wflows.SSHKeyGroupInfo, error)

DeleteSSHKeyGroupActivity deletes the sshkeygroup at carbide

func (*Workflows) GetSSHKeyGroupActivity ¶

func (ac *Workflows) GetSSHKeyGroupActivity(ctx context.Context, ResourceVer uint64, ResourceID string,
	ResourceReq *wflows.GetSSHKeyGroup) (*wflows.GetSSHKeyGroupResponse, error)

GetSSHKeyGroupActivity Gets the sshkeygroup at carbide

func (*Workflows) PublishSSHKeyGroupActivity ¶

func (ac *Workflows) PublishSSHKeyGroupActivity(ctx context.Context, TransactionID *wflows.TransactionID, SSHInfo *wflows.SSHKeyGroupInfo) (workflowID string, err error)

PublishSSHKeyGroupActivity - Publish SSHKeyGroup Info Activity

func (*Workflows) UpdateSSHKeyGroupActivity ¶

func (ac *Workflows) UpdateSSHKeyGroupActivity(ctx context.Context, ResourceVer uint64, ResourceID string,
	ResourceReq *wflows.UpdateSSHKeyGroupRequest) (*wflows.SSHKeyGroupInfo, error)

UpdateSSHKeyGroupActivity updates the sshkeygroup at carbide

Source Files ¶

View all Source files

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