simply

type AppConfig struct {
	Name string
}

type Command struct {
	AutoMigration bool
	EventStoreDB  *DBConfig
	Kafka         *KafkaConfig
}

type DBConfig struct {
	Host     string
	Port     string
	User     string
	Password string
	Database string
}

type EntityGenerator interface {
	CreateEntityAnsSave(events []*EventEntity) error
}

type Event interface {
	ID() uuid.UUID
	Type() string
	Time() time.Time
}

type EventEntity struct {
	ID          uint            `gorm:"primarykey"`
	UserNo      uint            `gorm:"index"`
	EventType   string          `gorm:"index"`
	AggregateId uuid.UUID       `gorm:"type:uuid;index"`
	Payload     json.RawMessage `gorm:"type:json"`
}

type EventModel struct {
	AggregateID uuid.UUID `json:"id" gorm:"type:uuid;column:id;index"`
	EventType   string    `json:"event_type" gorm:"index"`
	AppliedAt   time.Time `json:"applied_at"`
}

type EventStore interface {
	AddAndPublishEvent(userNo uint, event Event) (*EventEntity, error)
	GetAllEvents(aggregateId uuid.UUID) ([]*EventEntity, error)
	GetLastEvent(aggregateId uuid.UUID) (*EventEntity, error)
}

type KafkaConfig struct {
	BootstrapServers string
	Topic            string
	ConsumerGroup    string
}

type Observer interface {
	Run()
}

type Projector struct {
	AutoMigration bool
	Kafka         *KafkaConfig
}

type Query struct {
	AutoMigration bool
	EntityStoreDB *DBConfig
}