topic

Documentation

Index

• type EventType
• type Message
  • func NewMessage(eventType EventType, data interface{}) *Message
• type Service
  • func (svc *Service) Publish(ctx context.Context, data *Message) (*string, error)
  • func (svc *Service) UpdateTopicArn(ctx context.Context) error
• type TopicService
  • func NewService(topicName string, config aws.Config) TopicService

Types

type EventType

type EventType string

type Message

type Message struct {
	EventType EventType   `json:"event_type"`
	Data      interface{} `json:"data"`
}

func NewMessage

func NewMessage(eventType EventType, data interface{}) *Message

type Service

type Service struct {
	TopicName string
	TopicArn  string
	// contains filtered or unexported fields
}

func (*Service) Publish

func (svc *Service) Publish(ctx context.Context, data *Message) (*string, error)

func (*Service) UpdateTopicArn

func (svc *Service) UpdateTopicArn(ctx context.Context) error

type TopicService

type TopicService interface {
	UpdateTopicArn(ctx context.Context) error
	Publish(ctx context.Context, data *Message) (*string, error)
}

func NewService

func NewService(topicName string, config aws.Config) TopicService