Documentation
¶
Index ¶
- type ManageVpc
- func (mv ManageVpc) CreateVpcViaSiteAgent(ctx context.Context, siteID uuid.UUID, vpcID uuid.UUID) error
- func (mv ManageVpc) DeleteVpcViaSiteAgent(ctx context.Context, siteID uuid.UUID, vpcID uuid.UUID) error
- func (mv ManageVpc) UpdateVpcInDB(ctx context.Context, transactionID *cwssaws.TransactionID, ...) error
- func (mv ManageVpc) UpdateVpcMetadata(ctx context.Context, siteID uuid.UUID, tc client.Client, vpcID uuid.UUID, ...) error
- func (mv ManageVpc) UpdateVpcsInDB(ctx context.Context, siteID uuid.UUID, vpcInventory *cwssaws.VPCInventory) ([]cwm.InventoryObjectLifecycleEvent, error)
- type ManageVpcLifecycleMetrics
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ManageVpc ¶
type ManageVpc struct {
// contains filtered or unexported fields
}
ManageVpc is an activity wrapper for managing VPC lifecycle that allows injecting DB access
func NewManageVpc ¶
func NewManageVpc(dbSession *cdb.Session, siteClientPool *sc.ClientPool, tc client.Client) ManageVpc
NewManageVpc returns a new ManageVpc activity
func (ManageVpc) CreateVpcViaSiteAgent ¶
func (mv ManageVpc) CreateVpcViaSiteAgent(ctx context.Context, siteID uuid.UUID, vpcID uuid.UUID) error
CreateVpcViaSiteAgent is a Temporal activity that create a VPC in Site Controller via Site agent
func (ManageVpc) DeleteVpcViaSiteAgent ¶
func (mv ManageVpc) DeleteVpcViaSiteAgent(ctx context.Context, siteID uuid.UUID, vpcID uuid.UUID) error
DeleteVpcViaSiteAgent is a Temporal activity that delete a VPC in Site Controller via Site agent
func (ManageVpc) UpdateVpcInDB ¶
func (mv ManageVpc) UpdateVpcInDB(ctx context.Context, transactionID *cwssaws.TransactionID, vpcInfo *cwssaws.VPCInfo) error
UpdateVpcInDB updates the VPC in the DB from data pushed by Site Controller
func (ManageVpc) UpdateVpcMetadata ¶
func (mv ManageVpc) UpdateVpcMetadata(ctx context.Context, siteID uuid.UUID, tc client.Client, vpcID uuid.UUID, controllerVpc *cwssaws.Vpc) error
UpdateVpcMetadata is a Temporal activity that will trigger an update of an vpc's metadata if they are found out of sync with the cloud.
func (ManageVpc) UpdateVpcsInDB ¶
func (mv ManageVpc) UpdateVpcsInDB(ctx context.Context, siteID uuid.UUID, vpcInventory *cwssaws.VPCInventory) ([]cwm.InventoryObjectLifecycleEvent, error)
UpdateVpcsInDB is a Temporal activity that takes a collection of VPC data pushed by Site Agent and updates the DB
type ManageVpcLifecycleMetrics ¶
type ManageVpcLifecycleMetrics struct {
// contains filtered or unexported fields
}
ManageVpcLifecycleMetrics is an activity wrapper for managing VPC lifecycle metrics
func NewManageVpcLifecycleMetrics ¶
func NewManageVpcLifecycleMetrics(reg prometheus.Registerer, dbSession *cdb.Session) ManageVpcLifecycleMetrics
NewManageVpcLifecycleMetrics returns a new ManageVpcLifecycleMetrics activity
func (ManageVpcLifecycleMetrics) RecordVpcStatusTransitionMetrics ¶
func (mvlm ManageVpcLifecycleMetrics) RecordVpcStatusTransitionMetrics(ctx context.Context, siteID uuid.UUID, vpcLifecycleEvents []cwm.InventoryObjectLifecycleEvent) error
RecordVpcStatusTransitionMetrics is a Temporal activity that records duration of important status transitions for VPCs
Source Files