storage

Documentation

Index

• type DynamoDBTimestampStorage
  • func (s *DynamoDBTimestampStorage) CheckDependencies(ctx context.Context) error
  • func (s *DynamoDBTimestampStorage) FetchTimestamp(ctx context.Context) (time.Time, error)
  • func (s *DynamoDBTimestampStorage) StoreTimestamp(ctx context.Context, ts time.Time) error
• type DynamoDBTimestampStorageComponent
  • func (*DynamoDBTimestampStorageComponent) New(_ context.Context, c *DynamoDBTimestampStorageConfig) (*DynamoDBTimestampStorage, error)
  • func (*DynamoDBTimestampStorageComponent) Settings() *DynamoDBTimestampStorageConfig
• type DynamoDBTimestampStorageConfig
  • func (c *DynamoDBTimestampStorageConfig) Name() string

Types

type DynamoDBTimestampStorage

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

DynamoDBTimestampStorage provides persistence and retrieval of last processed scan timestamps from a DynamoDB table.

func (*DynamoDBTimestampStorage) CheckDependencies

func (s *DynamoDBTimestampStorage) CheckDependencies(ctx context.Context) error

CheckDependencies tries to communicate to the DB by trying to retrieve its tables

func (*DynamoDBTimestampStorage) FetchTimestamp

func (s *DynamoDBTimestampStorage) FetchTimestamp(ctx context.Context) (time.Time, error)

FetchTimestamp queries a DynamoDB table with a static partition key for the last processed timestamp.

func (*DynamoDBTimestampStorage) StoreTimestamp

func (s *DynamoDBTimestampStorage) StoreTimestamp(ctx context.Context, ts time.Time) error

StoreTimestamp upserts a timestamp to a DynamoDB table with a static partition key.

type DynamoDBTimestampStorageComponent

type DynamoDBTimestampStorageComponent struct{}

DynamoDBTimestampStorageComponent satisfies the settings library Component API, and may be used by the settings.NewComponent function.

func (*DynamoDBTimestampStorageComponent) New

func (*DynamoDBTimestampStorageComponent) New(_ context.Context, c *DynamoDBTimestampStorageConfig) (*DynamoDBTimestampStorage, error)

New constructs a DynamoDBTimestampStorage from a config.

func (*DynamoDBTimestampStorageComponent) Settings

func (*DynamoDBTimestampStorageComponent) Settings() *DynamoDBTimestampStorageConfig

Settings can be used to populate default values if there are any

type DynamoDBTimestampStorageConfig

type DynamoDBTimestampStorageConfig struct {
	TableName         string
	PartitionKeyName  string
	PartitionKeyValue string
	TimestampKeyName  string
	Region            string
	Endpoint          string
}

DynamoDBTimestampStorageConfig holds configuration required to send Nexpose assets to a queue via an HTTP Producer

func (*DynamoDBTimestampStorageConfig) Name

func (c *DynamoDBTimestampStorageConfig) Name() string

Name is used by the settings library and will add a "DYNAMODB" prefix to DynamoDBTimestampStorageConfig environment variables