s3

package
Version: v0.0.0-...-11a205f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 10, 2017 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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$.

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL