s3

Documentation

Index

• type Config
  • func (c *Config) IsValid() bool
  • func (c *Config) NewClient() (dialects.StorageClient, error)
• type S3Storage
  • func (c *S3Storage) GetBatchConverter() dialects.BatchConverter
  • func (c *S3Storage) GetConverter() dialects.Converter
  • func (c *S3Storage) IsBufferedStorage() bool
  • func (c *S3Storage) Save(msg *bytes.Buffer) error

Types

type Config

type Config struct {
	AccessKeyID     string `json:"access_key_id"`
	SecretAccessKey string `json:"secret_access_key"`
	Bucket          string `json:"bucket"`
	BlobPath        string `json:"blob_path"`
	Endpoint        string `json:"endpoint"`
	Region          string `json:"region"`
	FileFormat      string `json:"file_format"`
}

Amazon SNS configuration file.

func (*Config) IsValid

func (c *Config) IsValid() bool

Checks is it valid or not

func (*Config) NewClient

func (c *Config) NewClient() (dialects.StorageClient, error)

Create a new StorageClient object based on a configuration file.

type S3Storage

type S3Storage struct {
	AccessKeyID     string
	SecretAccessKey string
	Bucket          string
	BlobPath        string
	Region          string
	EndPoint        string
	FileFormat      string
	BatchConverter  dialects.BatchConverter
	Client          *s3.S3
}

SNS Storage's dialect.

func (*S3Storage) GetBatchConverter

func (c *S3Storage) GetBatchConverter() dialects.BatchConverter

Returns the batch converter function

func (*S3Storage) GetConverter

func (c *S3Storage) GetConverter() dialects.Converter

Returns the converter function

func (*S3Storage) IsBufferedStorage

func (c *S3Storage) IsBufferedStorage() bool

It is a buffered storage.

func (*S3Storage) Save

func (c *S3Storage) Save(msg *bytes.Buffer) error

Publish a batched Events to S$.