fetchers

Documentation

Index

• Variables
• type GcpAsset
  • func (r *GcpAsset) GetData() any
  • func (r *GcpAsset) GetElasticCommonData() (map[string]any, error)
  • func (r *GcpAsset) GetIds() []string
  • func (r *GcpAsset) GetMetadata() (fetching.ResourceMetadata, error)
• type GcpAssetsFetcher
  • func NewGcpAssetsFetcher(_ context.Context, log *logp.Logger, ch chan fetching.ResourceInfo, ...) *GcpAssetsFetcher
  • func (f *GcpAssetsFetcher) Fetch(ctx context.Context, cycleMetadata cycle.Metadata) error
  • func (f *GcpAssetsFetcher) Stop()
• type GcpLogSinkFetcher
  • func NewGcpLogSinkFetcher(_ context.Context, log *logp.Logger, ch chan fetching.ResourceInfo, ...) *GcpLogSinkFetcher
  • func (f *GcpLogSinkFetcher) Fetch(ctx context.Context, cycleMetadata cycle.Metadata) error
  • func (f *GcpLogSinkFetcher) Stop()
• type GcpLoggingAsset
  • func (g *GcpLoggingAsset) GetData() any
  • func (g *GcpLoggingAsset) GetElasticCommonData() (map[string]any, error)
  • func (g *GcpLoggingAsset) GetIds() []string
  • func (g *GcpLoggingAsset) GetMetadata() (fetching.ResourceMetadata, error)
• type GcpMonitoringAsset
  • func (g *GcpMonitoringAsset) GetData() any
  • func (g *GcpMonitoringAsset) GetElasticCommonData() (map[string]any, error)
  • func (g *GcpMonitoringAsset) GetIds() []string
  • func (g *GcpMonitoringAsset) GetMetadata() (fetching.ResourceMetadata, error)
• type GcpMonitoringFetcher
  • func NewGcpMonitoringFetcher(_ context.Context, log *logp.Logger, ch chan fetching.ResourceInfo, ...) *GcpMonitoringFetcher
  • func (f *GcpMonitoringFetcher) Fetch(ctx context.Context, cycleMetadata cycle.Metadata) error
  • func (f *GcpMonitoringFetcher) Stop()
• type GcpPoliciesAsset
  • func (g *GcpPoliciesAsset) GetData() any
  • func (g *GcpPoliciesAsset) GetElasticCommonData() (map[string]any, error)
  • func (g *GcpPoliciesAsset) GetIds() []string
  • func (g *GcpPoliciesAsset) GetMetadata() (fetching.ResourceMetadata, error)
• type GcpPoliciesFetcher
  • func NewGcpPoliciesFetcher(_ context.Context, log *logp.Logger, ch chan fetching.ResourceInfo, ...) *GcpPoliciesFetcher
  • func (f *GcpPoliciesFetcher) Fetch(ctx context.Context, cycleMetadata cycle.Metadata) error
  • func (f *GcpPoliciesFetcher) Stop()
• type GcpServiceUsageAsset
  • func (g *GcpServiceUsageAsset) GetData() any
  • func (g *GcpServiceUsageAsset) GetElasticCommonData() (map[string]any, error)
  • func (g *GcpServiceUsageAsset) GetIds() []string
  • func (g *GcpServiceUsageAsset) GetMetadata() (fetching.ResourceMetadata, error)
• type GcpServiceUsageFetcher
  • func NewGcpServiceUsageFetcher(_ context.Context, log *logp.Logger, ch chan fetching.ResourceInfo, ...) *GcpServiceUsageFetcher
  • func (f *GcpServiceUsageFetcher) Fetch(ctx context.Context, cycleMetadata cycle.Metadata) error
  • func (f *GcpServiceUsageFetcher) Stop()

Variables

var GcpAssetTypes = map[string][]string{
	fetching.ProjectManagement: {
		inventory.CrmProjectAssetType,
	},
	fetching.KeyManagement: {
		inventory.ApiKeysKeyAssetType,
		inventory.CloudKmsCryptoKeyAssetType,
	},
	fetching.CloudIdentity: {
		inventory.IamServiceAccountAssetType,
		inventory.IamServiceAccountKeyAssetType,
	},
	fetching.CloudDatabase: {
		inventory.BigqueryDatasetAssetType,
		inventory.BigqueryTableAssetType,
		inventory.SqlDatabaseInstanceAssetType,
	},
	fetching.CloudStorage: {
		inventory.StorageBucketAssetType,
		inventory.LogBucketAssetType,
	},
	fetching.CloudCompute: {
		inventory.ComputeInstanceAssetType,
		inventory.ComputeFirewallAssetType,
		inventory.ComputeDiskAssetType,
		inventory.ComputeNetworkAssetType,
		inventory.ComputeBackendServiceAssetType,
		inventory.ComputeSubnetworkAssetType,
	},
	fetching.CloudDns: {
		inventory.DnsManagedZoneAssetType,
	},
	fetching.DataProcessing: {
		inventory.DataprocClusterAssetType,
	},
}

GcpAssetTypes https://cloud.google.com/asset-inventory/docs/supported-asset-types map of types to asset types. sub-type is derived from asset type by using the first and last segments of the asset type name example: gcp-cloudkms-crypto-key

Types

type GcpAsset

type GcpAsset struct {
	Type    string
	SubType string

	ExtendedAsset *inventory.ExtendedGcpAsset `json:"asset,omitempty"`
}

func (*GcpAsset) GetData

func (r *GcpAsset) GetData() any

func (*GcpAsset) GetElasticCommonData

func (r *GcpAsset) GetElasticCommonData() (map[string]any, error)

func (*GcpAsset) GetIds

func (r *GcpAsset) GetIds() []string

func (*GcpAsset) GetMetadata

func (r *GcpAsset) GetMetadata() (fetching.ResourceMetadata, error)

type GcpAssetsFetcher

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

func NewGcpAssetsFetcher

func NewGcpAssetsFetcher(_ context.Context, log *logp.Logger, ch chan fetching.ResourceInfo, provider inventory.ServiceAPI) *GcpAssetsFetcher

func (*GcpAssetsFetcher) Fetch

func (f *GcpAssetsFetcher) Fetch(ctx context.Context, cycleMetadata cycle.Metadata) error

func (*GcpAssetsFetcher) Stop

func (f *GcpAssetsFetcher) Stop()

type GcpLogSinkFetcher

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

func NewGcpLogSinkFetcher

func NewGcpLogSinkFetcher(_ context.Context, log *logp.Logger, ch chan fetching.ResourceInfo, provider inventory.ServiceAPI) *GcpLogSinkFetcher

func (*GcpLogSinkFetcher) Fetch

func (f *GcpLogSinkFetcher) Fetch(ctx context.Context, cycleMetadata cycle.Metadata) error

func (*GcpLogSinkFetcher) Stop

func (f *GcpLogSinkFetcher) Stop()

type GcpLoggingAsset

type GcpLoggingAsset struct {
	Type string

	Asset *inventory.LoggingAsset `json:"asset,omitempty"`
	// contains filtered or unexported fields
}

func (*GcpLoggingAsset) GetData

func (g *GcpLoggingAsset) GetData() any

func (*GcpLoggingAsset) GetElasticCommonData

func (g *GcpLoggingAsset) GetElasticCommonData() (map[string]any, error)

func (*GcpLoggingAsset) GetIds

func (g *GcpLoggingAsset) GetIds() []string

func (*GcpLoggingAsset) GetMetadata

func (g *GcpLoggingAsset) GetMetadata() (fetching.ResourceMetadata, error)

type GcpMonitoringAsset

type GcpMonitoringAsset struct {
	Type string

	Asset *inventory.MonitoringAsset `json:"assets,omitempty"`
	// contains filtered or unexported fields
}

func (*GcpMonitoringAsset) GetData

func (g *GcpMonitoringAsset) GetData() any

func (*GcpMonitoringAsset) GetElasticCommonData

func (g *GcpMonitoringAsset) GetElasticCommonData() (map[string]any, error)

func (*GcpMonitoringAsset) GetIds

func (g *GcpMonitoringAsset) GetIds() []string

func (*GcpMonitoringAsset) GetMetadata

func (g *GcpMonitoringAsset) GetMetadata() (fetching.ResourceMetadata, error)

type GcpMonitoringFetcher

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

func NewGcpMonitoringFetcher

func NewGcpMonitoringFetcher(_ context.Context, log *logp.Logger, ch chan fetching.ResourceInfo, provider inventory.ServiceAPI) *GcpMonitoringFetcher

func (*GcpMonitoringFetcher) Fetch

func (f *GcpMonitoringFetcher) Fetch(ctx context.Context, cycleMetadata cycle.Metadata) error

func (*GcpMonitoringFetcher) Stop

func (f *GcpMonitoringFetcher) Stop()

type GcpPoliciesAsset

type GcpPoliciesAsset struct {
	Type string

	Asset *inventory.ProjectPoliciesAsset `json:"assets,omitempty"`
	// contains filtered or unexported fields
}

func (*GcpPoliciesAsset) GetData

func (g *GcpPoliciesAsset) GetData() any

func (*GcpPoliciesAsset) GetElasticCommonData

func (g *GcpPoliciesAsset) GetElasticCommonData() (map[string]any, error)

func (*GcpPoliciesAsset) GetIds

func (g *GcpPoliciesAsset) GetIds() []string

func (*GcpPoliciesAsset) GetMetadata

func (g *GcpPoliciesAsset) GetMetadata() (fetching.ResourceMetadata, error)

type GcpPoliciesFetcher

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

func NewGcpPoliciesFetcher

func NewGcpPoliciesFetcher(_ context.Context, log *logp.Logger, ch chan fetching.ResourceInfo, provider inventory.ServiceAPI) *GcpPoliciesFetcher

func (*GcpPoliciesFetcher) Fetch

func (f *GcpPoliciesFetcher) Fetch(ctx context.Context, cycleMetadata cycle.Metadata) error

func (*GcpPoliciesFetcher) Stop

func (f *GcpPoliciesFetcher) Stop()

type GcpServiceUsageAsset

type GcpServiceUsageAsset struct {
	Type string

	Asset *inventory.ServiceUsageAsset `json:"assets,omitempty"`
	// contains filtered or unexported fields
}

func (*GcpServiceUsageAsset) GetData

func (g *GcpServiceUsageAsset) GetData() any

func (*GcpServiceUsageAsset) GetElasticCommonData

func (g *GcpServiceUsageAsset) GetElasticCommonData() (map[string]any, error)

func (*GcpServiceUsageAsset) GetIds

func (g *GcpServiceUsageAsset) GetIds() []string

func (*GcpServiceUsageAsset) GetMetadata

func (g *GcpServiceUsageAsset) GetMetadata() (fetching.ResourceMetadata, error)

type GcpServiceUsageFetcher

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

func NewGcpServiceUsageFetcher

func NewGcpServiceUsageFetcher(_ context.Context, log *logp.Logger, ch chan fetching.ResourceInfo, provider inventory.ServiceAPI) *GcpServiceUsageFetcher

func (*GcpServiceUsageFetcher) Fetch

func (f *GcpServiceUsageFetcher) Fetch(ctx context.Context, cycleMetadata cycle.Metadata) error

func (*GcpServiceUsageFetcher) Stop

func (f *GcpServiceUsageFetcher) Stop()