sns

Documentation

Index

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

Types

type Config

type Config struct {
	AccessKeyID     string `json:"access_key_id"`
	SecretAccessKey string `json:"secret_access_key"`
	TopicArn        string `json:"topic_arn"`
	Region          string `json:"region"`
}

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 SNSStorage

type SNSStorage struct {
	AccessKeyID     string
	SecretAccessKey string
	TopicArn        string
	Region          string
	Client          *sns.SNS
}

SNS Storage's dialect.

func (*SNSStorage) GetBatchConverter

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

Returns the batch converter function

func (*SNSStorage) GetConverter

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

Returns the converter function

func (*SNSStorage) IsBufferedStorage

func (c *SNSStorage) IsBufferedStorage() bool

It is a buffered storage.

func (*SNSStorage) Save

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

Publish a single Event to SNS topic.