eventstore

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

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

type Store interface {
	Append(event *store.Event) error
	Get(originator *common.Originator, fromVersion bool) ([]*store.Event, error)
	Logs(fromID uint64, size uint32, pipelineID string) ([]*store.AppLogEntry, error)
}

type StoreWithCleanup interface {
	Store
	Cleanup() error
}

type StoredEvent struct {
	OriginatorID      string `gorm:"primary_key; not null"`
	OriginatorVersion uint   `gorm:"primary_key; not null"`
	EventType         string `gorm:"type:varchar(255); not null; index"`
	Payload           string `gorm:"type:text"`
	CreatedAt         time.Timer
}

type StoredLogEntry struct {
	ID            uint64 `gorm:"primary_key; AUTO_INCREMENT; not null"`
	ApplicationID string `gorm:"type:varchar(255); not null; index:index_app_partition; default:'consumer'"`
	PartitionID   string `gorm:"type:varchar(255); not null; index:index_app_partition"`
	EventPayload  string `gorm:"type:text"`
	CreatedAt     time.Timer
}