aqs

Documentation

Index

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

Types

type Config

type Config struct {
	Account   string `json:"account"`
	AccessKey string `json:"access_key"`
	QueueName string `json:"queue_name"`
}

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.

type QueueStorage

type QueueStorage struct {
	Account   string
	AccessKey string
	QueueName string
	Client    storage.QueueServiceClient
}

Azure Queue Storage dialect.

func (*QueueStorage) GetBatchConverter

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

Returns the batch converter function

func (*QueueStorage) GetConverter

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

Returns the converter function

func (*QueueStorage) IsBufferedStorage

func (c *QueueStorage) IsBufferedStorage() bool

It is a buffered storage.

func (*QueueStorage) Save

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

Send a single Event into the Azure Queue Storage.