abs

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: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

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