pubsub

type Broker struct {
	TopicARN        string
	QueueURL        string
	SubscriptionARN string
}

type Butler struct {
	Sns *sns.SNS
	Sqs *sqs.SQS
	// contains filtered or unexported fields
}

type Condition struct {
	ARNEquals map[string]string
}

type MessageBody struct {
	Message   string `json:"message"`
	Type      string `json:"type"`
	TopicARN  string `json:"topicArn"`
	MessageID string `json:"messageId"`
}

type PolicyDocument struct {
	Version   string
	ID        string
	Statement []StatementEntry
}

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

type StatementEntry struct {
	SID       string
	Effect    string
	Principal string
	Action    string
	Resource  string
	Condition Condition
}

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

type Usecase struct{}

type UserEvent struct {
	UserID string `json:"userId"`
	Status string `json:"status"`
	Time   int64  `json:"time"`
}