db

package
v0.16.0 Latest Latest
Warning

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

 Go to latest Published: May 7, 2025 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AWSRepoInterface 

type AWSRepoInterface interface {
	ListAWS(ctx context.Context, projectID, awsID uint32, awsAccountID string) (*[]model.AWS, error)
	GetAWSByAccountID(ctx context.Context, projectID uint32, awsAccountID string) (*model.AWS, error)
	UpsertAWS(ctx context.Context, data *model.AWS) (*model.AWS, error)
	DeleteAWS(ctx context.Context, projectID, awsID uint32) error
	ListAWSDataSource(ctx context.Context, projectID, awsID uint32, ds string) (*[]DataSource, error)
	ListDataSourceByAWSDataSourceID(ctx context.Context, awsDataSourceID uint32) (*[]DataSource, error)
	ListAWSRelDataSource(ctx context.Context, projectID, awsID uint32) (*[]model.AWSRelDataSource, error)
	UpsertAWSRelDataSource(ctx context.Context, data *aws.DataSourceForAttach) (*model.AWSRelDataSource, error)
	GetAWSRelDataSourceByID(ctx context.Context, awsID, awsDataSourceID, projectID uint32) (*model.AWSRelDataSource, error)
	DeleteAWSRelDataSource(ctx context.Context, projectID, awsID, awsDataSourceID uint32) error
	GetAWSDataSourceForMessage(ctx context.Context, awsID, awsDataSourceID, projectID uint32) (*DataSource, error)
	GetAWSRelDataSourceByAccountID(ctx context.Context, projectID uint32, awsAccountID string) (*model.AWSRelDataSource, error)
	ListAWSScanErrorForNotify(ctx context.Context) ([]*AWSScanError, error)
	UpdateAWSErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, awsID, awsDataSourceID, projectID uint32) error
}

type AWSScanError added in v0.9.0 

type AWSScanError struct {
	AWSID           uint32 `json:"aws_id"`
	AWSDataSourceID uint32 `json:"aws_data_source_id"`
	ProjectID       uint32 `json:"project_id"`
	DataSource      string `json:"data_source"`
	StatusDetail    string `json:"status_detail"`
}

type AzureRepoInterface added in v0.12.0 

type AzureRepoInterface interface {
	// azure_data_source
	ListAzureDataSource(ctx context.Context, azureDataSourceID uint32, name string) (*[]model.AzureDataSource, error)

	// azure
	ListAzure(ctx context.Context, projectID, azureID uint32, azureProjectID string) (*[]model.Azure, error)
	GetAzure(ctx context.Context, projectID, azureID uint32) (*model.Azure, error)
	UpsertAzure(ctx context.Context, azure *azure.AzureForUpsert) (*model.Azure, error)
	DeleteAzure(ctx context.Context, projectID uint32, azureID uint32) error

	// azure_data_source
	ListRelAzureDataSource(ctx context.Context, projectID, azureID uint32) (*[]RelAzureDataSource, error)
	GetRelAzureDataSource(ctx context.Context, projectID, azureID, azureDataSourceID uint32) (*RelAzureDataSource, error)
	UpsertRelAzureDataSource(ctx context.Context, relAzureDataSource *azure.RelAzureDataSourceForUpsert) (*RelAzureDataSource, error)
	DeleteRelAzureDataSource(ctx context.Context, projectID, azureID, azureDataSourceID uint32) error
	ListRelAzureDataSourceByDataSourceID(ctx context.Context, azureDataSourceID uint32) (*[]RelAzureDataSource, error)

	// scan_error
	ListAzureScanErrorForNotify(ctx context.Context) ([]*AzureScanError, error)
	UpdateAzureErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, azureID, azureDataSourceID, projectID uint32) error
}

type AzureScanError added in v0.12.0 

type AzureScanError struct {
	AzureID           uint32
	AzureDataSourceID uint32
	ProjectID         uint32
	DataSource        string
	StatusDetail      string
}

type Client 

type Client struct {
	MasterDB *gorm.DB
	SlaveDB  *gorm.DB
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(conf *Config, l logging.Logger) (*Client, error)

func (*Client) CleanWithNoProject added in v0.5.0 

func (c *Client) CleanWithNoProject(ctx context.Context) error

func (*Client) DeleteAWS 

func (c *Client) DeleteAWS(ctx context.Context, projectID, awsID uint32) error

func (*Client) DeleteAWSRelDataSource 

func (c *Client) DeleteAWSRelDataSource(ctx context.Context, projectID, awsID, awsDataSourceID uint32) error

func (*Client) DeleteApplicationScan 

func (c *Client) DeleteApplicationScan(ctx context.Context, projectID uint32, applicationScanID uint32) error

func (*Client) DeleteApplicationScanBasicSetting 

func (c *Client) DeleteApplicationScanBasicSetting(ctx context.Context, projectID uint32, applicationScanBasicSettingID uint32) error

func (*Client) DeleteAzure added in v0.12.0 

func (c *Client) DeleteAzure(ctx context.Context, projectID, azureID uint32) error

func (*Client) DeleteCodeScanSetting added in v0.10.0 

func (c *Client) DeleteCodeScanSetting(ctx context.Context, projectID uint32, githubSettingID uint32) error

func (*Client) DeleteDependencySetting added in v0.4.0 

func (c *Client) DeleteDependencySetting(ctx context.Context, projectID uint32, githubSettingID uint32) error

func (*Client) DeleteDiagnosisDataSource 

func (c *Client) DeleteDiagnosisDataSource(ctx context.Context, projectID uint32, diagnosisDataSourceID uint32) error

func (*Client) DeleteGCP 

func (c *Client) DeleteGCP(ctx context.Context, projectID, gcpID uint32) error

func (*Client) DeleteGCPDataSource 

func (c *Client) DeleteGCPDataSource(ctx context.Context, projectID, gcpID, googleDataSourceID uint32) error

func (*Client) DeleteGitHubSetting added in v0.4.0 

func (c *Client) DeleteGitHubSetting(ctx context.Context, projectID uint32, githubSettingID uint32) error

func (*Client) DeleteGitleaksCache added in v0.5.0 

func (c *Client) DeleteGitleaksCache(ctx context.Context, githubSettingID uint32) error

func (*Client) DeleteGitleaksSetting added in v0.4.0 

func (c *Client) DeleteGitleaksSetting(ctx context.Context, projectID uint32, githubSettingID uint32) error

func (*Client) DeleteOsint 

func (c *Client) DeleteOsint(ctx context.Context, projectID uint32, osintID uint32) error

func (*Client) DeleteOsintDataSource 

func (c *Client) DeleteOsintDataSource(ctx context.Context, projectID uint32, osintDataSourceID uint32) error

func (*Client) DeleteOsintDetectWord 

func (c *Client) DeleteOsintDetectWord(ctx context.Context, projectID uint32, osintDetectWordID uint32) error

func (*Client) DeletePortscanSetting 

func (c *Client) DeletePortscanSetting(ctx context.Context, projectID uint32, portscanSettingID uint32) error

func (*Client) DeletePortscanTarget 

func (c *Client) DeletePortscanTarget(ctx context.Context, projectID uint32, portscanTargetID uint32) error

func (*Client) DeletePortscanTargetByPortscanSettingID 

func (c *Client) DeletePortscanTargetByPortscanSettingID(ctx context.Context, projectID uint32, portscanSettingID uint32) error

func (*Client) DeleteRelAzureDataSource added in v0.12.0 

func (c *Client) DeleteRelAzureDataSource(ctx context.Context, projectID, azureID, azureDataSourceID uint32) error

func (*Client) DeleteRelOsintDataSource 

func (c *Client) DeleteRelOsintDataSource(ctx context.Context, projectID uint32, relOsintDataSourceID uint32) error

func (*Client) DeleteWpscanSetting 

func (c *Client) DeleteWpscanSetting(ctx context.Context, projectID uint32, wpscanSettingID uint32) error

func (*Client) GetAWSByAccountID 

func (c *Client) GetAWSByAccountID(ctx context.Context, projectID uint32, awsAccountID string) (*model.AWS, error)

func (*Client) GetAWSDataSourceForMessage 

func (c *Client) GetAWSDataSourceForMessage(ctx context.Context, awsID, awsDataSourceID, projectID uint32) (*DataSource, error)

func (*Client) GetAWSRelDataSourceByAccountID added in v0.9.0 

func (c *Client) GetAWSRelDataSourceByAccountID(ctx context.Context, projectID uint32, awsAccountID string) (*model.AWSRelDataSource, error)

func (*Client) GetAWSRelDataSourceByID 

func (c *Client) GetAWSRelDataSourceByID(ctx context.Context, awsID, awsDataSourceID, projectID uint32) (*model.AWSRelDataSource, error)

func (*Client) GetApplicationScan 

func (c *Client) GetApplicationScan(ctx context.Context, projectID uint32, applicationScanID uint32) (*model.ApplicationScan, error)

func (*Client) GetApplicationScanBasicSetting 

func (c *Client) GetApplicationScanBasicSetting(ctx context.Context, projectID uint32, applicationScanID uint32) (*model.ApplicationScanBasicSetting, error)

func (*Client) GetAzure added in v0.12.0 

func (c *Client) GetAzure(ctx context.Context, projectID, azureID uint32) (*model.Azure, error)

func (*Client) GetAzureBySubscriptionID added in v0.12.0 

func (c *Client) GetAzureBySubscriptionID(ctx context.Context, projectID uint32, subscriptionID string) (*model.Azure, error)

func (*Client) GetAzureDataSource added in v0.12.0 

func (c *Client) GetAzureDataSource(ctx context.Context, azureDataSourceID uint32) (*model.Azure, error)

func (*Client) GetCodeScanSetting added in v0.10.0 

func (c *Client) GetCodeScanSetting(ctx context.Context, projectID uint32, githubSettingID uint32) (*model.CodeCodeScanSetting, error)

func (*Client) GetDependencySetting added in v0.4.0 

func (c *Client) GetDependencySetting(ctx context.Context, projectID uint32, githubSettingID uint32) (*model.CodeDependencySetting, error)

func (*Client) GetDiagnosisDataSource 

func (c *Client) GetDiagnosisDataSource(ctx context.Context, projectID uint32, diagnosisDataSourceID uint32) (*model.DiagnosisDataSource, error)

func (*Client) GetGCP 

func (c *Client) GetGCP(ctx context.Context, projectID, gcpID uint32) (*model.GCP, error)

func (*Client) GetGCPByUniqueIndex 

func (c *Client) GetGCPByUniqueIndex(ctx context.Context, projectID uint32, gcpProjectID string) (*model.GCP, error)

func (*Client) GetGCPDataSource 

func (c *Client) GetGCPDataSource(ctx context.Context, projectID, gcpID, googleDataSourceID uint32) (*GCPDataSource, error)

func (*Client) GetGitHubSetting added in v0.4.0 

func (c *Client) GetGitHubSetting(ctx context.Context, projectID uint32, githubSettingID uint32) (*model.CodeGitHubSetting, error)

func (*Client) GetGitHubSettingByUniqueIndex added in v0.4.0 

func (c *Client) GetGitHubSettingByUniqueIndex(ctx context.Context, projectID uint32, name string) (*model.CodeGitHubSetting, error)

func (*Client) GetGitleaksCache added in v0.5.0 

func (c *Client) GetGitleaksCache(ctx context.Context, projectID, githubSettingID uint32, repositoryFullName string, immediately bool) (*model.CodeGitleaksCache, error)

func (*Client) GetGitleaksSetting added in v0.4.0 

func (c *Client) GetGitleaksSetting(ctx context.Context, projectID uint32, githubSettingID uint32) (*model.CodeGitleaksSetting, error)

func (*Client) GetGoogleDataSource 

func (c *Client) GetGoogleDataSource(ctx context.Context, googleDataSourceID uint32) (*model.GCP, error)

func (*Client) GetOsint 

func (c *Client) GetOsint(ctx context.Context, projectID uint32, osintID uint32) (*model.Osint, error)

func (*Client) GetOsintDataSource 

func (c *Client) GetOsintDataSource(ctx context.Context, projectID uint32, osintDataSourceID uint32) (*model.OsintDataSource, error)

func (*Client) GetOsintDetectWord 

func (c *Client) GetOsintDetectWord(ctx context.Context, projectID uint32, osintDetectWordID uint32) (*model.OsintDetectWord, error)

func (*Client) GetPortscanSetting 

func (c *Client) GetPortscanSetting(ctx context.Context, projectID uint32, portscanSettingID uint32) (*model.PortscanSetting, error)

func (*Client) GetPortscanTarget 

func (c *Client) GetPortscanTarget(ctx context.Context, projectID uint32, portscanTargetID uint32) (*model.PortscanTarget, error)

func (*Client) GetRelAzureDataSource added in v0.12.0 

func (c *Client) GetRelAzureDataSource(ctx context.Context, projectID, azureID, azureDataSourceID uint32) (*RelAzureDataSource, error)

func (*Client) GetRelOsintDataSource 

func (c *Client) GetRelOsintDataSource(ctx context.Context, projectID uint32, relOsintDataSourceID uint32) (*model.RelOsintDataSource, error)

func (*Client) GetWpscanSetting 

func (c *Client) GetWpscanSetting(ctx context.Context, projectID uint32, wpscanSettingID uint32) (*model.WpscanSetting, error)

func (*Client) ListAWS 

func (c *Client) ListAWS(ctx context.Context, projectID, awsID uint32, awsAccountID string) (*[]model.AWS, error)

func (*Client) ListAWSDataSource 

func (c *Client) ListAWSDataSource(ctx context.Context, projectID, awsID uint32, ds string) (*[]DataSource, error)

func (*Client) ListAWSRelDataSource 

func (c *Client) ListAWSRelDataSource(ctx context.Context, projectID, awsID uint32) (*[]model.AWSRelDataSource, error)

func (*Client) ListAWSScanErrorForNotify added in v0.9.0 

func (c *Client) ListAWSScanErrorForNotify(ctx context.Context) ([]*AWSScanError, error)

func (*Client) ListAllApplicationScan 

func (c *Client) ListAllApplicationScan(ctx context.Context) (*[]model.ApplicationScan, error)

func (*Client) ListAllPortscanSetting 

func (c *Client) ListAllPortscanSetting(ctx context.Context) (*[]model.PortscanSetting, error)

func (*Client) ListAllRelOsintDataSource 

func (c *Client) ListAllRelOsintDataSource(ctx context.Context, osintDataSourceID uint32) (*[]model.RelOsintDataSource, error)

func (*Client) ListAllWpscanSetting 

func (c *Client) ListAllWpscanSetting(ctx context.Context) (*[]model.WpscanSetting, error)

func (*Client) ListApplicationScan 

func (c *Client) ListApplicationScan(ctx context.Context, projectID, diagnoosisDataSourceID uint32) (*[]model.ApplicationScan, error)

func (*Client) ListApplicationScanBasicSetting 

func (c *Client) ListApplicationScanBasicSetting(ctx context.Context, projectID, applicationScanID uint32) (*[]model.ApplicationScanBasicSetting, error)

func (*Client) ListAzure added in v0.12.0 

func (c *Client) ListAzure(ctx context.Context, projectID, azureID uint32, azureProjectID string) (*[]model.Azure, error)

func (*Client) ListAzureDataSource added in v0.12.0 

func (c *Client) ListAzureDataSource(ctx context.Context, azureDataSourceID uint32, name string) (*[]model.AzureDataSource, error)

func (*Client) ListAzureScanErrorForNotify added in v0.12.0 

func (c *Client) ListAzureScanErrorForNotify(ctx context.Context) ([]*AzureScanError, error)

func (*Client) ListCodeDataSource 

func (c *Client) ListCodeDataSource(ctx context.Context, codeDataSourceID uint32, name string) (*[]model.CodeDataSource, error)

func (*Client) ListCodeGitHubScanErrorForNotify added in v0.9.0 

func (c *Client) ListCodeGitHubScanErrorForNotify(ctx context.Context) ([]*GitHubScanError, error)

func (*Client) ListCodeScanSetting added in v0.10.0 

func (c *Client) ListCodeScanSetting(ctx context.Context, projectID uint32) (*[]model.CodeCodeScanSetting, error)

func (*Client) ListDataSourceByAWSDataSourceID 

func (c *Client) ListDataSourceByAWSDataSourceID(ctx context.Context, dataSourceID uint32) (*[]DataSource, error)

func (*Client) ListDependencySetting added in v0.4.0 

func (c *Client) ListDependencySetting(ctx context.Context, projectID uint32) (*[]model.CodeDependencySetting, error)

func (*Client) ListDiagnosisDataSource 

func (c *Client) ListDiagnosisDataSource(ctx context.Context, projectID uint32, name string) (*[]model.DiagnosisDataSource, error)

func (*Client) ListDiagnosisScanErrorForNotify added in v0.9.0 

func (c *Client) ListDiagnosisScanErrorForNotify(ctx context.Context) ([]*DiagnosisScanError, error)

func (*Client) ListGCP 

func (c *Client) ListGCP(ctx context.Context, projectID, gcpID uint32, gcpProjectID string) (*[]model.GCP, error)

func (*Client) ListGCPDataSource 

func (c *Client) ListGCPDataSource(ctx context.Context, projectID, gcpID uint32) (*[]GCPDataSource, error)

func (*Client) ListGCPDataSourceByDataSourceID 

func (c *Client) ListGCPDataSourceByDataSourceID(ctx context.Context, googleDataSourceID uint32) (*[]GCPDataSource, error)

func (*Client) ListGCPScanErrorForNotify added in v0.9.0 

func (c *Client) ListGCPScanErrorForNotify(ctx context.Context) ([]*GCPScanError, error)

func (*Client) ListGitHubSetting added in v0.4.0 

func (c *Client) ListGitHubSetting(ctx context.Context, projectID, githubSettingID uint32) (*[]model.CodeGitHubSetting, error)

func (*Client) ListGitleaksCache added in v0.9.0 

func (c *Client) ListGitleaksCache(ctx context.Context, projectID, githubSettingID uint32) (*[]model.CodeGitleaksCache, error)

func (*Client) ListGitleaksSetting added in v0.4.0 

func (c *Client) ListGitleaksSetting(ctx context.Context, projectID uint32) (*[]model.CodeGitleaksSetting, error)

func (*Client) ListGoogleDataSource 

func (c *Client) ListGoogleDataSource(ctx context.Context, googleDataSourceID uint32, name string) (*[]model.GoogleDataSource, error)

func (*Client) ListOsint 

func (c *Client) ListOsint(ctx context.Context, projectID uint32) (*[]model.Osint, error)

func (*Client) ListOsintDataSource 

func (c *Client) ListOsintDataSource(ctx context.Context, projectID uint32, name string) (*[]model.OsintDataSource, error)

func (*Client) ListOsintDetectWord 

func (c *Client) ListOsintDetectWord(ctx context.Context, projectID, relOsintDataSourceID uint32) (*[]model.OsintDetectWord, error)

func (*Client) ListOsintScanErrorForNotify added in v0.9.0 

func (c *Client) ListOsintScanErrorForNotify(ctx context.Context) ([]*OsintScanError, error)

func (*Client) ListPortscanSetting 

func (c *Client) ListPortscanSetting(ctx context.Context, projectID, diagnoosisDataSourceID uint32) (*[]model.PortscanSetting, error)

func (*Client) ListPortscanTarget 

func (c *Client) ListPortscanTarget(ctx context.Context, projectID, portscanSettingID uint32) (*[]model.PortscanTarget, error)

func (*Client) ListRelAzureDataSource added in v0.12.0 

func (c *Client) ListRelAzureDataSource(ctx context.Context, projectID, azureID uint32) (*[]RelAzureDataSource, error)

func (*Client) ListRelAzureDataSourceByDataSourceID added in v0.12.0 

func (c *Client) ListRelAzureDataSourceByDataSourceID(ctx context.Context, azureDataSourceID uint32) (*[]RelAzureDataSource, error)

func (*Client) ListRelOsintDataSource 

func (c *Client) ListRelOsintDataSource(ctx context.Context, projectID, osintID, osintDataSourceID uint32) (*[]model.RelOsintDataSource, error)

func (*Client) ListWpscanSetting 

func (c *Client) ListWpscanSetting(ctx context.Context, projectID, diagnoosisDataSourceID uint32) (*[]model.WpscanSetting, error)

func (*Client) UpdateAWSErrorNotifiedAt added in v0.9.0 

func (c *Client) UpdateAWSErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, awsID, awsDataSourceID, projectID uint32) error

func (*Client) UpdateAzureErrorNotifiedAt added in v0.12.0 

func (c *Client) UpdateAzureErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, azureID, azureDataSourceID, projectID uint32) error

func (*Client) UpdateCodeCodeScanErrorNotifiedAt added in v0.10.0 

func (c *Client) UpdateCodeCodeScanErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, codeGithubSettingID, projectID uint32) error

func (*Client) UpdateCodeDependencyErrorNotifiedAt added in v0.9.0 

func (c *Client) UpdateCodeDependencyErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, codeGithubSettingID, projectID uint32) error

func (*Client) UpdateCodeGitleaksErrorNotifiedAt added in v0.9.0 

func (c *Client) UpdateCodeGitleaksErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, codeGithubSettingID, projectID uint32) error

func (*Client) UpdateDiagnosisAppScanErrorNotifiedAt added in v0.9.0 

func (c *Client) UpdateDiagnosisAppScanErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, scanID, projectID uint32) error

func (*Client) UpdateDiagnosisPortscanErrorNotifiedAt added in v0.9.0 

func (c *Client) UpdateDiagnosisPortscanErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, scanID, projectID uint32) error

func (*Client) UpdateDiagnosisWpscanErrorNotifiedAt added in v0.9.0 

func (c *Client) UpdateDiagnosisWpscanErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, scanID, projectID uint32) error

func (*Client) UpdateGCPErrorNotifiedAt added in v0.9.0 

func (c *Client) UpdateGCPErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, gcpID, googleDataSourceID, projectID uint32) error

func (*Client) UpdateOsintErrorNotifiedAt added in v0.9.0 

func (c *Client) UpdateOsintErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, relOsintDataSourceID, projectID uint32) error

func (*Client) UpsertAWS 

func (c *Client) UpsertAWS(ctx context.Context, data *model.AWS) (*model.AWS, error)

func (*Client) UpsertAWSRelDataSource 

func (c *Client) UpsertAWSRelDataSource(ctx context.Context, data *aws.DataSourceForAttach) (*model.AWSRelDataSource, error)

func (*Client) UpsertApplicationScan 

func (c *Client) UpsertApplicationScan(ctx context.Context, data *model.ApplicationScan) (*model.ApplicationScan, error)

func (*Client) UpsertApplicationScanBasicSetting 

func (c *Client) UpsertApplicationScanBasicSetting(ctx context.Context, data *model.ApplicationScanBasicSetting) (*model.ApplicationScanBasicSetting, error)

func (*Client) UpsertAzure added in v0.12.0 

func (c *Client) UpsertAzure(ctx context.Context, azure *azure.AzureForUpsert) (*model.Azure, error)

func (*Client) UpsertCodeScanSetting added in v0.10.0 

func (c *Client) UpsertCodeScanSetting(ctx context.Context, data *code.CodeScanSettingForUpsert) (*model.CodeCodeScanSetting, error)

func (*Client) UpsertDependencySetting added in v0.4.0 

func (c *Client) UpsertDependencySetting(ctx context.Context, data *code.DependencySettingForUpsert) (*model.CodeDependencySetting, error)

func (*Client) UpsertDiagnosisDataSource 

func (c *Client) UpsertDiagnosisDataSource(ctx context.Context, input *model.DiagnosisDataSource) (*model.DiagnosisDataSource, error)

func (*Client) UpsertGCP 

func (c *Client) UpsertGCP(ctx context.Context, gcp *google.GCPForUpsert) (*model.GCP, error)

func (*Client) UpsertGCPDataSource 

func (c *Client) UpsertGCPDataSource(ctx context.Context, gcpDataSource *google.GCPDataSourceForUpsert) (*GCPDataSource, error)

func (*Client) UpsertGitHubSetting added in v0.4.0 

func (c *Client) UpsertGitHubSetting(ctx context.Context, data *code.GitHubSettingForUpsert) (*model.CodeGitHubSetting, error)

func (*Client) UpsertGitHubSettingWithToken added in v0.4.0 

func (c *Client) UpsertGitHubSettingWithToken(ctx context.Context, data *code.GitHubSettingForUpsert) (*model.CodeGitHubSetting, error)

func (*Client) UpsertGitHubSettingWithoutToken added in v0.4.0 

func (c *Client) UpsertGitHubSettingWithoutToken(ctx context.Context, data *code.GitHubSettingForUpsert) (*model.CodeGitHubSetting, error)

func (*Client) UpsertGitleaksCache added in v0.5.0 

func (c *Client) UpsertGitleaksCache(ctx context.Context, projectID uint32, data *code.GitleaksCacheForUpsert) (*model.CodeGitleaksCache, error)

func (*Client) UpsertGitleaksSetting added in v0.4.0 

func (c *Client) UpsertGitleaksSetting(ctx context.Context, data *code.GitleaksSettingForUpsert) (*model.CodeGitleaksSetting, error)

func (*Client) UpsertOsint 

func (c *Client) UpsertOsint(ctx context.Context, data *model.Osint) (*model.Osint, error)

func (*Client) UpsertOsintDataSource 

func (c *Client) UpsertOsintDataSource(ctx context.Context, input *model.OsintDataSource) (*model.OsintDataSource, error)

func (*Client) UpsertOsintDetectWord 

func (c *Client) UpsertOsintDetectWord(ctx context.Context, data *model.OsintDetectWord) (*model.OsintDetectWord, error)

func (*Client) UpsertPortscanSetting 

func (c *Client) UpsertPortscanSetting(ctx context.Context, data *model.PortscanSetting) (*model.PortscanSetting, error)

func (*Client) UpsertPortscanTarget 

func (c *Client) UpsertPortscanTarget(ctx context.Context, data *model.PortscanTarget) (*model.PortscanTarget, error)

func (*Client) UpsertRelAzureDataSource added in v0.12.0 

func (c *Client) UpsertRelAzureDataSource(ctx context.Context, relAzureDataSource *azure.RelAzureDataSourceForUpsert) (*RelAzureDataSource, error)

func (*Client) UpsertRelOsintDataSource 

func (c *Client) UpsertRelOsintDataSource(ctx context.Context, data *model.RelOsintDataSource) (*model.RelOsintDataSource, error)

func (*Client) UpsertWpscanSetting 

func (c *Client) UpsertWpscanSetting(ctx context.Context, data *model.WpscanSetting) (*model.WpscanSetting, error)

type CodeRepoInterface 

type CodeRepoInterface interface {
	// code_data_source
	ListCodeDataSource(ctx context.Context, codeDataSourceID uint32, name string) (*[]model.CodeDataSource, error)

	// code_github_setting
	ListGitHubSetting(ctx context.Context, projectID, githubSettingID uint32) (*[]model.CodeGitHubSetting, error)
	GetGitHubSetting(ctx context.Context, projectID, GitHubSettingID uint32) (*model.CodeGitHubSetting, error)
	UpsertGitHubSetting(ctx context.Context, data *code.GitHubSettingForUpsert) (*model.CodeGitHubSetting, error)
	DeleteGitHubSetting(ctx context.Context, projectID uint32, GitHubSettingID uint32) error

	// code_gitleaks_setting
	ListGitleaksSetting(ctx context.Context, projectID uint32) (*[]model.CodeGitleaksSetting, error)
	GetGitleaksSetting(ctx context.Context, projectID, githubSettingID uint32) (*model.CodeGitleaksSetting, error)
	UpsertGitleaksSetting(ctx context.Context, data *code.GitleaksSettingForUpsert) (*model.CodeGitleaksSetting, error)
	DeleteGitleaksSetting(ctx context.Context, projectID uint32, GitHubSettingID uint32) error

	// code_gitleaks_cache
	ListGitleaksCache(ctx context.Context, projectID, githubSettingID uint32) (*[]model.CodeGitleaksCache, error)
	GetGitleaksCache(ctx context.Context, projectID, githubSettingID uint32, repositoryFullName string, immediately bool) (*model.CodeGitleaksCache, error)
	UpsertGitleaksCache(ctx context.Context, projectID uint32, data *code.GitleaksCacheForUpsert) (*model.CodeGitleaksCache, error)
	DeleteGitleaksCache(ctx context.Context, githubSettingID uint32) error

	// code_dependency_setting
	ListDependencySetting(ctx context.Context, projectID uint32) (*[]model.CodeDependencySetting, error)
	GetDependencySetting(ctx context.Context, projectID, githubSettingID uint32) (*model.CodeDependencySetting, error)
	UpsertDependencySetting(ctx context.Context, data *code.DependencySettingForUpsert) (*model.CodeDependencySetting, error)
	DeleteDependencySetting(ctx context.Context, projectID uint32, GitHubSettingID uint32) error

	// code_code_scan_setting
	ListCodeScanSetting(ctx context.Context, projectID uint32) (*[]model.CodeCodeScanSetting, error)
	GetCodeScanSetting(ctx context.Context, projectID, githubSettingID uint32) (*model.CodeCodeScanSetting, error)
	UpsertCodeScanSetting(ctx context.Context, data *code.CodeScanSettingForUpsert) (*model.CodeCodeScanSetting, error)
	DeleteCodeScanSetting(ctx context.Context, projectID uint32, GitHubSettingID uint32) error

	// scan error
	ListCodeGitHubScanErrorForNotify(ctx context.Context) ([]*GitHubScanError, error)
	UpdateCodeGitleaksErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, codeGithubSettingID, projectID uint32) error
	UpdateCodeDependencyErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, codeGithubSettingID, projectID uint32) error
	UpdateCodeCodeScanErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, codeGithubSettingID, projectID uint32) error
}

type Config 

type Config struct {
	MasterHost     string
	MasterUser     string
	MasterPassword string
	SlaveHost      string
	SlaveUser      string
	SlavePassword  string

	Schema        string
	Port          int
	LogMode       bool
	MaxConnection int
}

type DataSource 

type DataSource struct {
	AWSDataSourceID uint32
	DataSource      string
	MaxScore        float32
	AWSID           uint32 `gorm:"column:aws_id"`
	ProjectID       uint32
	AWSAccountID    string
	AssumeRoleArn   string
	ExternalID      string
	SpecificVersion string
	Status          string
	StatusDetail    string
	ScanAt          time.Time
}

type DataSourceRepoInterface added in v0.5.0 

type DataSourceRepoInterface interface {
	CleanWithNoProject(ctx context.Context) error
}

type DiagnosisRepoInterface 

type DiagnosisRepoInterface interface {
	ListDiagnosisDataSource(context.Context, uint32, string) (*[]model.DiagnosisDataSource, error)
	GetDiagnosisDataSource(context.Context, uint32, uint32) (*model.DiagnosisDataSource, error)
	UpsertDiagnosisDataSource(context.Context, *model.DiagnosisDataSource) (*model.DiagnosisDataSource, error)
	DeleteDiagnosisDataSource(context.Context, uint32, uint32) error
	ListWpscanSetting(context.Context, uint32, uint32) (*[]model.WpscanSetting, error)
	GetWpscanSetting(context.Context, uint32, uint32) (*model.WpscanSetting, error)
	UpsertWpscanSetting(context.Context, *model.WpscanSetting) (*model.WpscanSetting, error)
	DeleteWpscanSetting(context.Context, uint32, uint32) error
	ListPortscanSetting(context.Context, uint32, uint32) (*[]model.PortscanSetting, error)
	GetPortscanSetting(context.Context, uint32, uint32) (*model.PortscanSetting, error)
	UpsertPortscanSetting(context.Context, *model.PortscanSetting) (*model.PortscanSetting, error)
	DeletePortscanSetting(context.Context, uint32, uint32) error
	ListPortscanTarget(context.Context, uint32, uint32) (*[]model.PortscanTarget, error)
	GetPortscanTarget(context.Context, uint32, uint32) (*model.PortscanTarget, error)
	UpsertPortscanTarget(context.Context, *model.PortscanTarget) (*model.PortscanTarget, error)
	DeletePortscanTarget(context.Context, uint32, uint32) error
	DeletePortscanTargetByPortscanSettingID(context.Context, uint32, uint32) error
	ListApplicationScan(context.Context, uint32, uint32) (*[]model.ApplicationScan, error)
	GetApplicationScan(context.Context, uint32, uint32) (*model.ApplicationScan, error)
	UpsertApplicationScan(context.Context, *model.ApplicationScan) (*model.ApplicationScan, error)
	DeleteApplicationScan(context.Context, uint32, uint32) error
	ListApplicationScanBasicSetting(context.Context, uint32, uint32) (*[]model.ApplicationScanBasicSetting, error)
	GetApplicationScanBasicSetting(context.Context, uint32, uint32) (*model.ApplicationScanBasicSetting, error)
	UpsertApplicationScanBasicSetting(context.Context, *model.ApplicationScanBasicSetting) (*model.ApplicationScanBasicSetting, error)
	DeleteApplicationScanBasicSetting(context.Context, uint32, uint32) error

	//for InvokeScan
	ListAllWpscanSetting(context.Context) (*[]model.WpscanSetting, error)

	// scan error
	ListDiagnosisScanErrorForNotify(ctx context.Context) ([]*DiagnosisScanError, error)
	UpdateDiagnosisWpscanErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, scanID, projectID uint32) error
	UpdateDiagnosisPortscanErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, scanID, projectID uint32) error
	UpdateDiagnosisAppScanErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, scanID, projectID uint32) error
}

type DiagnosisScanError added in v0.9.0 

type DiagnosisScanError struct {
	ScanID       uint32
	ProjectID    uint32
	DataSource   string
	StatusDetail string
}

type GCPDataSource 

type GCPDataSource struct {
	GCPID              uint32 `gorm:"primary_key column:gcp_id"`
	GoogleDataSourceID uint32 `gorm:"primary_key"`
	ProjectID          uint32
	SpecificVersion    string
	Status             string
	StatusDetail       string
	ScanAt             time.Time
	CreatedAt          time.Time
	UpdatedAt          time.Time
	Name               string  // google_data_source.name
	Description        string  // google_data_source.description
	MaxScore           float32 // google_data_source.max_score
	GCPProjectID       string  // gcp.gcp_project_id
	ErrorNotifiedAt    time.Time
}

type GCPScanError added in v0.9.0 

type GCPScanError struct {
	GCPID              uint32
	GoogleDataSourceID uint32
	ProjectID          uint32
	DataSource         string
	StatusDetail       string
}

type GitHubScanError added in v0.9.0 

type GitHubScanError struct {
	CodeGithubSettingID uint32
	ProjectID           uint32
	DataSource          string
	StatusDetail        string
}

type GoogleRepoInterface 

type GoogleRepoInterface interface {
	// google_data_source
	ListGoogleDataSource(ctx context.Context, googleDataSourceID uint32, name string) (*[]model.GoogleDataSource, error)

	// gcp
	ListGCP(ctx context.Context, projectID, gcpID uint32, gcpProjectID string) (*[]model.GCP, error)
	GetGCP(ctx context.Context, projectID, gcpID uint32) (*model.GCP, error)
	UpsertGCP(ctx context.Context, gcp *google.GCPForUpsert) (*model.GCP, error)
	DeleteGCP(ctx context.Context, projectID uint32, gcpID uint32) error

	// gcp_data_source
	ListGCPDataSource(ctx context.Context, projectID, gcpID uint32) (*[]GCPDataSource, error)
	GetGCPDataSource(ctx context.Context, projectID, gcpID, googleDataSourceID uint32) (*GCPDataSource, error)
	UpsertGCPDataSource(ctx context.Context, gcpDataSource *google.GCPDataSourceForUpsert) (*GCPDataSource, error)
	DeleteGCPDataSource(ctx context.Context, projectID, gcpID, googleDataSourceID uint32) error
	ListGCPDataSourceByDataSourceID(ctx context.Context, googleDataSourceID uint32) (*[]GCPDataSource, error)

	// scan_error
	ListGCPScanErrorForNotify(ctx context.Context) ([]*GCPScanError, error)
	UpdateGCPErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, gcpID, googleDataSourceID, projectID uint32) error
}

type OSINTRepoInterface 

type OSINTRepoInterface interface {
	ListOsint(context.Context, uint32) (*[]model.Osint, error)
	GetOsint(context.Context, uint32, uint32) (*model.Osint, error)
	UpsertOsint(context.Context, *model.Osint) (*model.Osint, error)
	DeleteOsint(context.Context, uint32, uint32) error
	ListOsintDataSource(context.Context, uint32, string) (*[]model.OsintDataSource, error)
	GetOsintDataSource(context.Context, uint32, uint32) (*model.OsintDataSource, error)
	UpsertOsintDataSource(context.Context, *model.OsintDataSource) (*model.OsintDataSource, error)
	DeleteOsintDataSource(context.Context, uint32, uint32) error
	ListRelOsintDataSource(context.Context, uint32, uint32, uint32) (*[]model.RelOsintDataSource, error)
	GetRelOsintDataSource(context.Context, uint32, uint32) (*model.RelOsintDataSource, error)
	UpsertRelOsintDataSource(context.Context, *model.RelOsintDataSource) (*model.RelOsintDataSource, error)
	DeleteRelOsintDataSource(context.Context, uint32, uint32) error
	ListOsintDetectWord(context.Context, uint32, uint32) (*[]model.OsintDetectWord, error)
	GetOsintDetectWord(context.Context, uint32, uint32) (*model.OsintDetectWord, error)
	UpsertOsintDetectWord(context.Context, *model.OsintDetectWord) (*model.OsintDetectWord, error)
	DeleteOsintDetectWord(context.Context, uint32, uint32) error
	// For Invoke
	ListAllRelOsintDataSource(context.Context, uint32) (*[]model.RelOsintDataSource, error)

	// scan error
	ListOsintScanErrorForNotify(ctx context.Context) ([]*OsintScanError, error)
	UpdateOsintErrorNotifiedAt(ctx context.Context, errNotifiedAt interface{}, relOsintDataSourceID, projectID uint32) error
}

type OsintScanError added in v0.9.0 

type OsintScanError struct {
	RelOsintDataSourceID uint32 `json:"rel_osint_data_source"`
	ProjectID            uint32 `json:"project_id"`
	DataSource           string `json:"data_source"`
	StatusDetail         string `json:"status_detail"`
}

type RelAzureDataSource added in v0.12.0 

type RelAzureDataSource struct {
	AzureID           uint32 `gorm:"primary_key column:azure_id"`
	AzureDataSourceID uint32 `gorm:"primary_key"`
	ProjectID         uint32
	Status            string
	StatusDetail      string
	ScanAt            time.Time
	CreatedAt         time.Time
	UpdatedAt         time.Time
	Name              string  // azure_data_source.name
	Description       string  // azure_data_source.description
	MaxScore          float32 // azure_data_source.max_score
	SubscriptionID    string  // azure.subscription_id
	ErrorNotifiedAt   time.Time
}

Source Files

View all Source files

Directories

Path Synopsis

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.