aws

Documentation

Index

• Constants
• func NewS3Destination(destinationConfig internal.DestinationConfig) (internal.Destination, error)
• type Config
• type S3Adapter
  • func (s *S3Adapter) ForSet(setName string, setConfigJson json.RawMessage) error
  • func (s *S3Adapter) Write(data []byte, eventLog chan<- internal.EventLogItem) error
• type S3Config
• type S3Set

Constants

const (
	DefaultObjectNamePrefix = "data_"
)

Functions

func NewS3Destination

func NewS3Destination(destinationConfig internal.DestinationConfig) (internal.Destination, error)

Types

type Config

type Config struct {
	AccessKeyId     string
	SecretAccessKey string
	Region          string
}

type S3Adapter

type S3Adapter struct {
	// DestinationConfig contains configuration common to all adapters
	DestinationConfig internal.DestinationConfig

	// S3Config contains configuration specific to this adapter
	S3Config S3Config

	// S3Set contains configuration that differs for each archive set
	S3Set S3Set
}

func (*S3Adapter) ForSet

func (s *S3Adapter) ForSet(setName string, setConfigJson json.RawMessage) error

func (*S3Adapter) Write

func (s *S3Adapter) Write(data []byte, eventLog chan<- internal.EventLogItem) error

type S3Config

type S3Config struct {
	AwsConfig  Config
	BucketName string
}

type S3Set

type S3Set struct {
	ObjectNamePrefix string `json:"ObjectNamePrefix"`
}