api

Documentation

Index

• Constants
• Variables
• func AddPermissionToLogProcessorQueue(accountID string) (bool, error)
• func RemovePermissionFromLogProcessorQueue(accountID string) error
• func ScanAllResources(integrations []*models.SourceIntegrationMetadata) error
• type API
  • func (API) CheckIntegration(input *models.CheckIntegrationInput) (*models.SourceIntegrationHealth, error)
  • func (API) DeleteIntegration(input *models.DeleteIntegrationInput) (err error)
  • func (API) GetIntegrationTemplate(input *models.GetIntegrationTemplateInput) (*models.SourceIntegrationTemplate, error)
  • func (API) ListIntegrations(input *models.ListIntegrationsInput) ([]*models.SourceIntegration, error)
  • func (api API) PutIntegration(input *models.PutIntegrationInput) (*models.SourceIntegrationMetadata, error)
  • func (API) UpdateIntegrationLastScanEnd(input *models.UpdateIntegrationLastScanEndInput) (*models.SourceIntegration, error)
  • func (API) UpdateIntegrationLastScanStart(input *models.UpdateIntegrationLastScanStartInput) (*models.SourceIntegration, error)
  • func (api API) UpdateIntegrationSettings(input *models.UpdateIntegrationSettingsInput) (*models.SourceIntegration, error)
• type SqsPolicy
• type SqsPolicyStatement

Constants

const (
	TemplateBucket           = "panther-public-cloudformation-templates"
	TemplateBucketRegion     = endpoints.UsWest2RegionID
	CloudSecurityTemplateKey = "panther-cloudsec-iam/v1.0.0/template.yml"
	LogAnalysisTemplateKey   = "panther-log-analysis-iam/v1.0.0/template.yml"

	LogAnalysisStackNameTemplate = "panther-log-analysis-setup-%s"
	CloudSecStackName            = "panther-cloudsec-setup"
)

Variables

var (
	SQSClient sqsiface.SQSAPI = sqs.New(sess)
)

Functions

func AddPermissionToLogProcessorQueue

func AddPermissionToLogProcessorQueue(accountID string) (bool, error)

AddPermissionToLogProcessorQueue modifies the SQS Queue policy of the Log Processor to allow SNS topic from new account to subscribe to it

func RemovePermissionFromLogProcessorQueue

func RemovePermissionFromLogProcessorQueue(accountID string) error

RemovePermissionFromLogProcessorQueue modifies the SQS Queue policy of the Log Processor so that SNS topics from that account cannot subscribe to the queue

func ScanAllResources

func ScanAllResources(integrations []*models.SourceIntegrationMetadata) error

ScanAllResources schedules scans for each Resource type for each integration.

Each Resource type is sent within its own SQS message.

Types

type API

type API struct{}

API provides receiver methods for each route handler.

func (API) CheckIntegration

func (API) CheckIntegration(input *models.CheckIntegrationInput) (*models.SourceIntegrationHealth, error)

CheckIntegration adds a set of new integrations in a batch.

func (API) DeleteIntegration

func (API) DeleteIntegration(input *models.DeleteIntegrationInput) (err error)

DeleteIntegration deletes a specific integration.

func (API) GetIntegrationTemplate

func (API) GetIntegrationTemplate(input *models.GetIntegrationTemplateInput) (*models.SourceIntegrationTemplate, error)

GetIntegrationTemplate generates a new satellite account CloudFormation template based on the given parameters.

func (API) ListIntegrations

func (API) ListIntegrations(
	input *models.ListIntegrationsInput) ([]*models.SourceIntegration, error)

ListIntegrations returns all enabled integrations across each organization.

The output of this handler is used to schedule pollers.

func (API) PutIntegration

func (api API) PutIntegration(input *models.PutIntegrationInput) (*models.SourceIntegrationMetadata, error)

PutIntegration adds a set of new integrations in a batch.

func (API) UpdateIntegrationLastScanEnd

func (API) UpdateIntegrationLastScanEnd(input *models.UpdateIntegrationLastScanEndInput) (*models.SourceIntegration, error)

UpdateIntegrationLastScanEnd updates an integration when a scan ends.

func (API) UpdateIntegrationLastScanStart

func (API) UpdateIntegrationLastScanStart(input *models.UpdateIntegrationLastScanStartInput) (*models.SourceIntegration, error)

UpdateIntegrationLastScanStart updates an integration when a new scan is started.

func (API) UpdateIntegrationSettings

func (api API) UpdateIntegrationSettings(input *models.UpdateIntegrationSettingsInput) (*models.SourceIntegration, error)

UpdateIntegrationSettings makes an update to an integration from the UI.

This endpoint updates attributes such as the behavior of the integration, or display information.

type SqsPolicy

type SqsPolicy struct {
	Version    string               `json:"Version"`
	Statements []SqsPolicyStatement `json:"Statement"`
}

type SqsPolicyStatement

type SqsPolicyStatement struct {
	SID       string            `json:"Sid"`
	Effect    string            `json:"Effect"`
	Principal map[string]string `json:"Principal"`
	Action    string            `json:"Action"`
	Resource  string            `json:"Resource"`
	Condition interface{}       `json:"Condition"`
}