example

type DynamoClient interface {
	PutItem(ctx context.Context, params *dynamodb.PutItemInput, optFns ...func(*dynamodb.Options)) (*dynamodb.PutItemOutput, error)
}

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

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

type EventReceiverOption func(er *EventReceiver)

type IDGenerator func() string

type SQSClient interface {
	SendMessage(ctx context.Context, params *sqs.SendMessageInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageOutput, error)
}

type SomeDomainEvent struct {
	ID      string `json:"id"`
	Message string `json:"message"`
	Source  string `json:"source"`
}