eventstream

Documentation

Index

• type EventPayload
• type Publisher
  • func NewPublisher(cfgs ...*aws.Config) *Publisher
  • func (pb *Publisher) SendEvent(ctx context.Context, topicName string, subject string, requestId string, ...) error
  • func (pb *Publisher) SendNotification(ctx context.Context, topicName string, subject string, msg string) error

Types

type EventPayload

type EventPayload struct {
	AwsRequestID string            `json:"aws_request_id,omitempty"`
	Attributes   map[string]string `json:"attributes,omitempty"`
}

type Publisher

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

func NewPublisher

func NewPublisher(cfgs ...*aws.Config) *Publisher

NewPublisher new publisher

func (*Publisher) SendEvent

func (pb *Publisher) SendEvent(ctx context.Context, topicName string, subject string, requestId string, attributes map[string]string) error

func (*Publisher) SendNotification

func (pb *Publisher) SendNotification(ctx context.Context, topicName string, subject string, msg string) error