publisher

Documentation

Index

• func ConvertCredentials[T IPublisherOptions](creds string) T
• type AwsOptions
• type IPublisher
  • func NewPublisher(publisherType PublisherType, credentials string) IPublisher
• type IPublisherOptions
• type PublisherType
• type SnsPublisher
  • func NewSnsPublisher(options AwsOptions) SnsPublisher
  • func (p SnsPublisher) Publish(message string)
• type SqsPublisher
  • func NewSqsPublisher(options AwsOptions) SqsPublisher
  • func (p SqsPublisher) Publish(message string)

Functions

func ConvertCredentials

func ConvertCredentials[T IPublisherOptions](creds string) T

Types

type AwsOptions

type AwsOptions struct {
	AccessKey   string `json:"access_key"`
	SecretKey   string `json:"secret_key"`
	Region      string `validate:"required"`
	QueueUrl    string `json:"queue"`
	SnsTopicArn string `json:"sns"`
}

type IPublisher

type IPublisher interface {
	Publish(message string)
}

func NewPublisher

func NewPublisher(publisherType PublisherType, credentials string) IPublisher

type IPublisherOptions

type IPublisherOptions interface {
	// contains filtered or unexported methods
}

type PublisherType

type PublisherType string

const (
	AwsSQS PublisherType = "sqs"
	AwsSNS               = "sns"
)

type SnsPublisher

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

func NewSnsPublisher

func NewSnsPublisher(options AwsOptions) SnsPublisher

func (SnsPublisher) Publish

func (p SnsPublisher) Publish(message string)

type SqsPublisher

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

func NewSqsPublisher

func NewSqsPublisher(options AwsOptions) SqsPublisher

func (SqsPublisher) Publish

func (p SqsPublisher) Publish(message string)