fetchers

package
v0.0.0-...-a42049d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 6, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

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) 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) 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) 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) 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) GetMetadata

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()

Jump to

Keyboard shortcuts

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