abs

Documentation

Index

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

Types

type BlobStorage

type BlobStorage struct {
	Account        string
	AccessKey      string
	Container      string
	BlobPath       string
	FileFormat     string
	BatchConverter dialects.BatchConverter
	Client         storage.BlobStorageClient
}

Azure Queue Storage dialect.

func (*BlobStorage) GetBatchConverter

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

Returns the converter function

func (*BlobStorage) GetConverter

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

There is no normal converter for ABS

func (*BlobStorage) IsBufferedStorage

func (c *BlobStorage) IsBufferedStorage() bool

It is a buffered storage.

func (*BlobStorage) Save

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

Send a single Event into the Azure Queue Storage.

type Config

type Config struct {
	Account    string `json:"account"`
	AccessKey  string `json:"access_key"`
	Container  string `json:"container"`
	BlobPath   string `json:"blob_path"`
	FileFormat string `json:"file_format"`
}

Azure Queue Storage 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.