aws_sqs

Documentation

Index

• type AwsSqsPub
  • func (k *AwsSqsPub) GetName() string
  • func (k *AwsSqsPub) Initialize(configuration util.Configuration) (err error)
  • func (k *AwsSqsPub) SendMessage(key string, message proto.Message) (err error)

Types

type AwsSqsPub

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

func (*AwsSqsPub) GetName

func (k *AwsSqsPub) GetName() string

func (*AwsSqsPub) Initialize

func (k *AwsSqsPub) Initialize(configuration util.Configuration) (err error)

func (*AwsSqsPub) SendMessage

func (k *AwsSqsPub) SendMessage(key string, message proto.Message) (err error)