queue

Documentation

Index

• type Client
  • func NewClient(ctx context.Context, conf *SQSConfig, l logging.Logger) (*Client, error)
  • func (c *Client) Send(ctx context.Context, url string, msg interface{}) (*sqs.SendMessageOutput, error)
• type SQSConfig

Types

type Client

type Client struct {

	// aws
	AWSGuardDutyQueueURL      string
	AWSAccessAnalyzerQueueURL string
	AWSAdminCheckerQueueURL   string
	AWSCloudSploitQueueURL    string
	AWSPortscanQueueURL       string

	// google
	GoogleAssetQueueURL          string
	GoogleCloudSploitQueueURL    string
	GoogleCloudSploitOldQueueURL string
	GoogleSCCQueueURL            string
	GooglePortscanQueueURL       string

	// code
	CodeGitleaksQueueURL   string
	CodeDependencyQueueURL string

	// osint
	OSINTSubdomainQueueURL string
	OSINTWebsiteQueueURL   string

	// diagnosis
	DiagnosisWpscanQueueURL          string
	DiagnosisPortscanQueueURL        string
	DiagnosisApplicationScanQueueURL string
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ctx context.Context, conf *SQSConfig, l logging.Logger) (*Client, error)

func (*Client) Send

func (c *Client) Send(ctx context.Context, url string, msg interface{}) (*sqs.SendMessageOutput, error)

type SQSConfig

type SQSConfig struct {
	AWSRegion   string
	SQSEndpoint string

	// aws
	AWSGuardDutyQueueURL      string
	AWSAccessAnalyzerQueueURL string
	AWSAdminCheckerQueueURL   string
	AWSCloudSploitQueueURL    string
	AWSPortscanQueueURL       string

	// google
	GoogleAssetQueueURL          string
	GoogleCloudSploitQueueURL    string
	GoogleCloudSploitOldQueueURL string
	GoogleSCCQueueURL            string
	GooglePortscanQueueURL       string

	// code
	CodeGitleaksQueueURL   string
	CodeDependencyQueueURL string

	// osint
	OSINTSubdomainQueueURL string
	OSINTWebsiteQueueURL   string

	// diagnosis
	DiagnosisWpscanQueueURL          string
	DiagnosisPortscanQueueURL        string
	DiagnosisApplicationScanQueueURL string
}