event

type Consumer interface {
	SubscribeEvent(ctx context.Context, topic string, handler MessageHandlerFunc) error
	Close() error
}

type DomainEvent struct {
	ID        uuid.UUID   // 事件唯一ID
	EventType string      // 事件的Type名稱，例如：AccountCreatedEvent
	Data      interface{} // 事件資料，例如&AccountCreatedEvent{}
	CreatedAt time.Time

	AggregateType string // 事件所屬的Aggregate Type，例如AccountCreatedEvent屬於Account
	AggregateID   string // aggregate儲存在資料庫，相對應的ID
	Version       int    // aggregate的版本
}

type Event interface {
	GetEventType() string
	GetData() interface{}
	CreatedAt() time.Time

	GetAggregateType() string
	GetAggregateID() string
	GetVersion() int

	Serialize() (string, error)
	Deserialize(string) (interface{}, error)
}

type MessageHandlerFunc func(key string, message string) error

type Producer interface {
	// PublishEvent publish event to pubsub server.
	PublishEvent(ctx context.Context, topic string, event interface{}) error

	// Close connection.
	Close() error
}

type RoleCreatedEvent struct {
	Name        string   `json:"name"`
	Description string   `json:"description"`
	Permissions []string `json:"permissions"`
}

type RoleDescriptionChangedEvent struct {
	Description string `json:"description"`
}

type RolePermissionUpdatedEvent struct {
	Permissions []string `json:"permissions"`
}

type Store interface {
	Store(ctx context.Context, events []DomainEvent, version int) error
	Load(ctx context.Context, aggregateID string, version int) ([]DomainEvent, error)
	SafeStore(ctx context.Context, events []DomainEvent, expectedVersion int) error
}

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

type UserCreatedEvent struct {
	UserName string `json:"user_name"`
	Password string `json:"password"`
	EMail    string `json:"email"`
}

type UserEmailChangedEvent struct {
	EMail string `json:"email"`
}

type UserPasswordChangedEvent struct {
	Password string `json:"password"`
}