pubsub

Documentation

Index

• type Publisher
• type PublisherFactory
  • func (s PublisherFactory) GetInstance(publisherType PublisherType, config any) (Publisher, error)
• type PublisherType
• type SNSPublisher
  • func GetSNSPublisher(config map[string]string) *SNSPublisher
  • func (s *SNSPublisher) Publish(topic string, message string, params map[string]any) error

Types

type Publisher

type Publisher interface {
	Publish(topic string, message string, params map[string]any) error
}

type PublisherFactory

type PublisherFactory struct{}

func (PublisherFactory) GetInstance

func (s PublisherFactory) GetInstance(publisherType PublisherType, config any) (Publisher, error)

type PublisherType

type PublisherType string

const (
	SNS PublisherType = "sns"
)

type SNSPublisher

type SNSPublisher struct {
	Client *sns.Client
	// contains filtered or unexported fields
}

func GetSNSPublisher

func GetSNSPublisher(config map[string]string) *SNSPublisher

func (*SNSPublisher) Publish

func (s *SNSPublisher) Publish(topic string, message string, params map[string]any) error