query_resource

Documentation

Index

• Constants
• Variables
• type CloudResourceInfo
• type ResourceRefreshService
  • func NewResourceRefreshService(config util.Config) (*ResourceRefreshService, error)
  • func (r *ResourceRefreshService) FetchCloudAccountResources(accountsToRefresh []util.AccountsToRefresh, completeRefresh bool)
  • func (r *ResourceRefreshService) FetchCloudResources(organizationAccounts []util.MonitoredAccount)
  • func (r *ResourceRefreshService) GetRefreshCount() int32
  • func (r *ResourceRefreshService) Initialize()
  • func (r *ResourceRefreshService) Lock()
  • func (r *ResourceRefreshService) QueryAndRegisterResources(accountsToRefresh []util.AccountsToRefresh, completeRefresh bool) []error
  • func (r *ResourceRefreshService) SetResourceRefreshStatus(account util.AccountsToRefresh, refreshStatus string, ...)
  • func (r *ResourceRefreshService) SkipCloudAuditLogUpdate(accountID string) bool
  • func (r *ResourceRefreshService) Unlock()
• type SteampipeQueryResponse

Constants

const (
	Ec2DnsSuffix1 = ".compute.amazonaws.com"
	Ec2DnsSuffix2 = ".ec2.internal"
)

Variables

var (
	AzureCloudTablesJson = `` /* 20503-byte string literal not displayed */

	AzureADCloudTablesJson = `` /* 722-byte string literal not displayed */

)

var (
	AWSCloudTablesJson = `` /* 30618-byte string literal not displayed */

)

var (
	CloudResourcesFile = util.InstallDirectory + "/var/log/fenced/cloud-resources/cloud_resources.log"
)

var (
	GCPCloudTablesJson = `` /* 7291-byte string literal not displayed */

)

Types

type CloudResourceInfo

type CloudResourceInfo struct {
	Table    string   `json:"table,omitempty"`
	Columns  []string `json:"columns,omitempty"`
	IdColumn string   `json:"id_column,omitempty"`
}

type ResourceRefreshService

type ResourceRefreshService struct {
	CloudResourceChanges cloud_resource_changes.CloudResourceChanges
	// contains filtered or unexported fields
}

func NewResourceRefreshService

func NewResourceRefreshService(config util.Config) (*ResourceRefreshService, error)

func (*ResourceRefreshService) FetchCloudAccountResources

func (r *ResourceRefreshService) FetchCloudAccountResources(accountsToRefresh []util.AccountsToRefresh, completeRefresh bool)

FetchCloudAccountResources Fetch cloud resources from selected accounts and resource types

func (*ResourceRefreshService) FetchCloudResources

func (r *ResourceRefreshService) FetchCloudResources(organizationAccounts []util.MonitoredAccount)

FetchCloudResources Fetch cloud resources from all accounts

func (*ResourceRefreshService) GetRefreshCount

func (r *ResourceRefreshService) GetRefreshCount() int32

func (*ResourceRefreshService) Initialize

func (r *ResourceRefreshService) Initialize()

func (*ResourceRefreshService) Lock

func (r *ResourceRefreshService) Lock()

func (*ResourceRefreshService) QueryAndRegisterResources

func (r *ResourceRefreshService) QueryAndRegisterResources(accountsToRefresh []util.AccountsToRefresh, completeRefresh bool) []error

func (*ResourceRefreshService) SetResourceRefreshStatus

func (r *ResourceRefreshService) SetResourceRefreshStatus(account util.AccountsToRefresh, refreshStatus string, refreshMetadata util.RefreshMetadata)

func (*ResourceRefreshService) SkipCloudAuditLogUpdate

func (r *ResourceRefreshService) SkipCloudAuditLogUpdate(accountID string) bool

SkipCloudAuditLogUpdate Weather to skip cloud audit log based resource updates

func (*ResourceRefreshService) Unlock

func (r *ResourceRefreshService) Unlock()

type SteampipeQueryResponse

type SteampipeQueryResponse struct {
	Rows []map[string]interface{} `json:"rows"`
}