sqs

Documentation

Index

• type SQSConfigManager
  • func (k *SQSConfigManager) GetConfig() *aws.Config
  • func (k *SQSConfigManager) GetConnection() interface{}
  • func (k *SQSConfigManager) NewSession() *session.Session
  • func (k *SQSConfigManager) ReleaseConnection(connection interface{})
  • func (k *SQSConfigManager) Start() error
  • func (k *SQSConfigManager) Stop() error
  • func (k *SQSConfigManager) Type() string
• type SQSFactory
  • func (*SQSFactory) NewManager(settings map[string]interface{}) (connection.Manager, error)
  • func (*SQSFactory) Type() string

Types

type SQSConfigManager

type SQSConfigManager struct {
	// contains filtered or unexported fields
}

func (*SQSConfigManager) GetConfig

func (k *SQSConfigManager) GetConfig() *aws.Config

func (*SQSConfigManager) GetConnection

func (k *SQSConfigManager) GetConnection() interface{}

func (*SQSConfigManager) NewSession

func (k *SQSConfigManager) NewSession() *session.Session

func (*SQSConfigManager) ReleaseConnection

func (k *SQSConfigManager) ReleaseConnection(connection interface{})

func (*SQSConfigManager) Start

func (k *SQSConfigManager) Start() error

func (*SQSConfigManager) Stop

func (k *SQSConfigManager) Stop() error

func (*SQSConfigManager) Type

func (k *SQSConfigManager) Type() string

type SQSFactory

type SQSFactory struct {
}

func (*SQSFactory) NewManager

func (*SQSFactory) NewManager(settings map[string]interface{}) (connection.Manager, error)

func (*SQSFactory) Type

func (*SQSFactory) Type() string