eventbus

Documentation

Index

• Variables
• type Message
• type MessageHandler
• type Publisher
  • func NewEventBridgePublisher(sess *session.Session, cfg *PublisherConfig) (Publisher, error)
• type PublisherConfig
• type SqsMessage
• type Subscriber
  • func NewSQSSubscriber(sess *session.Session, cfg *SubscriberConfig) (Subscriber, error)
• type SubscriberConfig

Variables

var (
	ErrNilMessage = errors.New("nil message")
)

Types

type Message

type Message struct {
	ID      string            `json:"id"`
	Key     string            `json:"key"`
	Headers map[string]string `json:"headers"`
	Body    string            `json:"body"`
}

type MessageHandler

type MessageHandler func(message *Message)

type Publisher

type Publisher interface {
	Publish(ctx context.Context, msg *Message) error
}

func NewEventBridgePublisher

func NewEventBridgePublisher(sess *session.Session, cfg *PublisherConfig) (Publisher, error)

type PublisherConfig

type PublisherConfig struct {
	Source       string
	EventBusName string
}

type SqsMessage

type SqsMessage struct {
	Version    string    `json:"version"`
	ID         string    `json:"id"`
	DetailType string    `json:"detail-type"`
	Source     string    `json:"source"`
	Account    string    `json:"account"`
	Time       time.Time `json:"time"`
	Region     string    `json:"region"`
	Detail     *Message  `json:"detail"`
}

type Subscriber

type Subscriber interface {
	Subscribe(key string, fn MessageHandler)
	Start(ctx context.Context) error
	Stop()
}

func NewSQSSubscriber

func NewSQSSubscriber(sess *session.Session, cfg *SubscriberConfig) (Subscriber, error)

type SubscriberConfig

type SubscriberConfig struct {
	Source         string
	EventBusName   string
	QueueUrl       string
	MaxWorker      int
	MaxMsg         int
	DefaultHandler MessageHandler
	Timeout        time.Duration
}