fetchers

package
v0.0.0-...-b8cf163 Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AzureAssetGroups = []string{inventory.AssetGroupResources, inventory.AssetGroupAuthorizationResources}

In order to simplify the mappings, we are trying to query all AzureAssetTypeToTypePair on every asset group Because this is done with an "|"" this means that we won't get irrelevant data

View Source 
var AzureAssetTypeToTypePair = map[string]typePair{
	inventory.ClassicStorageAccountAssetType:     {fetching.AzureClassicStorageAccountType, fetching.CloudStorage},
	inventory.DiskAssetType:                      {fetching.AzureDiskType, fetching.CloudCompute},
	inventory.DocumentDBDatabaseAccountAssetType: {fetching.AzureDocumentDBDatabaseAccountType, fetching.CloudDatabase},
	inventory.MySQLDBAssetType:                   {fetching.AzureMySQLDBType, fetching.CloudDatabase},
	inventory.FlexibleMySQLDBAssetType:           {fetching.AzureFlexibleMySQLDBType, fetching.CloudDatabase},
	inventory.NetworkWatchersFlowLogAssetType:    {fetching.AzureNetworkWatchersFlowLogType, fetching.MonitoringIdentity},
	inventory.FlexiblePostgreSQLDBAssetType:      {fetching.AzureFlexiblePostgreSQLDBType, fetching.CloudDatabase},
	inventory.PostgreSQLDBAssetType:              {fetching.AzurePostgreSQLDBType, fetching.CloudDatabase},
	inventory.SQLServersAssetType:                {fetching.AzureSQLServerType, fetching.CloudDatabase},
	inventory.StorageAccountAssetType:            {fetching.AzureStorageAccountType, fetching.CloudStorage},
	inventory.VirtualMachineAssetType:            {fetching.AzureVMType, fetching.CloudCompute},
	inventory.WebsitesAssetType:                  {fetching.AzureWebSiteType, fetching.CloudCompute},
	inventory.VaultAssetType:                     {fetching.AzureVaultType, fetching.KeyManagement},
	inventory.RoleDefinitionsType:                {fetching.AzureRoleDefinitionType, fetching.CloudIdentity},

	inventory.NetworkSecurityGroupAssetType: {fetching.AzureNetworkSecurityGroupType, fetching.MonitoringIdentity},
}
View Source 
var AzureBatchAssetGroups = []string{inventory.AssetGroupResources}

In order to simplify the mappings, we are trying to query all AzureBatchAssets on every asset group Because this is done with an "|"" this means that we won't get irrelevant data

View Source 
var AzureBatchAssets = map[string]typePair{
	inventory.ActivityLogAlertAssetType: {fetching.AzureActivityLogAlertType, fetching.MonitoringIdentity},
	inventory.ApplicationInsights:       {fetching.AzureInsightsComponentType, fetching.MonitoringIdentity},
	inventory.BastionAssetType:          {fetching.AzureBastionType, fetching.CloudDns},
}
View Source 
var AzureSecurityAssetTypeToTypePair = map[string]typePair{
	inventory.SecurityContactsAssetType:            {fetching.AzureSecurityContactsType, fetching.MonitoringIdentity},
	inventory.SecurityAutoProvisioningSettingsType: {fetching.AzureAutoProvisioningSettingsType, fetching.MonitoringIdentity},
}

Functions

This section is empty.

Types

type AssetsEnricher 

type AssetsEnricher interface {
	Enrich(ctx context.Context, cycleMetadata cycle.Metadata, assets []inventory.AzureAsset) error
}

type AzureAssetsFetcher 

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

func NewAzureAssetsFetcher 

func NewAzureAssetsFetcher(log *clog.Logger, ch chan fetching.ResourceInfo, provider azurelib.ProviderAPI) *AzureAssetsFetcher

func (*AzureAssetsFetcher) Fetch 

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

func (*AzureAssetsFetcher) Stop 

func (f *AzureAssetsFetcher) Stop()

type AzureBatchAssetFetcher 

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

func NewAzureBatchAssetFetcher 

func NewAzureBatchAssetFetcher(log *clog.Logger, ch chan fetching.ResourceInfo, provider azurelib.ProviderAPI) *AzureBatchAssetFetcher

func (*AzureBatchAssetFetcher) Fetch 

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

func (*AzureBatchAssetFetcher) Stop 

func (f *AzureBatchAssetFetcher) Stop()

type AzureBatchResource 

type AzureBatchResource struct {
	Subscription governance.Subscription
	Assets       []inventory.AzureAsset `json:"assets,omitempty"`
	// contains filtered or unexported fields
}

func (*AzureBatchResource) GetData 

func (r *AzureBatchResource) GetData() any

func (*AzureBatchResource) GetElasticCommonData 

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

func (*AzureBatchResource) GetIds 

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

func (*AzureBatchResource) GetMetadata 

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

type AzureInsightsBatchAssetFetcher 

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

func NewAzureInsightsBatchAssetFetcher 

func NewAzureInsightsBatchAssetFetcher(log *clog.Logger, ch chan fetching.ResourceInfo, provider azurelib.ProviderAPI) *AzureInsightsBatchAssetFetcher

func (*AzureInsightsBatchAssetFetcher) Fetch 

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

func (*AzureInsightsBatchAssetFetcher) Stop 

func (f *AzureInsightsBatchAssetFetcher) Stop()

type AzureLocationsNetworkWatcherAssetBatchFetcher 

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

func NewAzureLocationsNetworkWatcherAssetBatchFetcher 

func NewAzureLocationsNetworkWatcherAssetBatchFetcher(log *clog.Logger, ch chan fetching.ResourceInfo, provider azurelib.ProviderAPI) *AzureLocationsNetworkWatcherAssetBatchFetcher

func (*AzureLocationsNetworkWatcherAssetBatchFetcher) Fetch 

func (f *AzureLocationsNetworkWatcherAssetBatchFetcher) Fetch(ctx context.Context, metadata cycle.Metadata) error

func (*AzureLocationsNetworkWatcherAssetBatchFetcher) Stop 

func (f *AzureLocationsNetworkWatcherAssetBatchFetcher) Stop()

type AzureResource 

type AzureResource struct {
	Type         string
	SubType      string
	Asset        inventory.AzureAsset `json:"asset,omitempty"`
	Subscription governance.Subscription
}

func (*AzureResource) GetData 

func (r *AzureResource) GetData() any

func (*AzureResource) GetElasticCommonData 

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

func (*AzureResource) GetIds 

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

func (*AzureResource) GetMetadata 

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

type AzureSecurityAssetFetcher 

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

func NewAzureSecurityAssetFetcher 

func NewAzureSecurityAssetFetcher(log *clog.Logger, ch chan fetching.ResourceInfo, provider azurelib.ProviderAPI) *AzureSecurityAssetFetcher

func (*AzureSecurityAssetFetcher) Fetch 

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

func (*AzureSecurityAssetFetcher) Stop 

func (f *AzureSecurityAssetFetcher) Stop()

type MockAssetsEnricher 

type MockAssetsEnricher struct {
	mock.Mock
}

MockAssetsEnricher is an autogenerated mock type for the AssetsEnricher type

func NewMockAssetsEnricher 

func NewMockAssetsEnricher(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockAssetsEnricher

NewMockAssetsEnricher creates a new instance of MockAssetsEnricher. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockAssetsEnricher) EXPECT 

func (_m *MockAssetsEnricher) EXPECT() *MockAssetsEnricher_Expecter

func (*MockAssetsEnricher) Enrich 

func (_m *MockAssetsEnricher) Enrich(ctx context.Context, cycleMetadata cycle.Metadata, assets []inventory.AzureAsset) error

Enrich provides a mock function with given fields: ctx, cycleMetadata, assets

type MockAssetsEnricher_Enrich_Call 

type MockAssetsEnricher_Enrich_Call struct {
	*mock.Call
}

MockAssetsEnricher_Enrich_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Enrich'

func (*MockAssetsEnricher_Enrich_Call) Return 

func (_c *MockAssetsEnricher_Enrich_Call) Return(_a0 error) *MockAssetsEnricher_Enrich_Call

func (*MockAssetsEnricher_Enrich_Call) Run 

func (_c *MockAssetsEnricher_Enrich_Call) Run(run func(ctx context.Context, cycleMetadata cycle.Metadata, assets []inventory.AzureAsset)) *MockAssetsEnricher_Enrich_Call

func (*MockAssetsEnricher_Enrich_Call) RunAndReturn 

func (_c *MockAssetsEnricher_Enrich_Call) RunAndReturn(run func(context.Context, cycle.Metadata, []inventory.AzureAsset) error) *MockAssetsEnricher_Enrich_Call

type MockAssetsEnricher_Expecter 

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

func (*MockAssetsEnricher_Expecter) Enrich 

func (_e *MockAssetsEnricher_Expecter) Enrich(ctx interface{}, cycleMetadata interface{}, assets interface{}) *MockAssetsEnricher_Enrich_Call

Enrich is a helper method to define mock.On call

  • ctx context.Context
  • cycleMetadata cycle.Metadata
  • assets []inventory.AzureAsset

type NetworkWatchersBatchedByLocationResource 

type NetworkWatchersBatchedByLocationResource struct {
	Subscription    governance.Subscription `json:"subscription"`
	Location        inventory.AzureAsset    `json:"location"`
	NetworkWatchers []inventory.AzureAsset  `json:"networkWatchers,omitempty"`
	// contains filtered or unexported fields
}

func (*NetworkWatchersBatchedByLocationResource) GetData 

func (r *NetworkWatchersBatchedByLocationResource) GetData() any

func (*NetworkWatchersBatchedByLocationResource) GetElasticCommonData 

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

func (*NetworkWatchersBatchedByLocationResource) GetIds 

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

func (*NetworkWatchersBatchedByLocationResource) GetMetadata 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.