goes

type Aggregate interface {
	GetAggregateBase() *AggregateBase
}

type AggregateBase struct {
	ID       string
	Type     string
	Revision int
	Version  int
	Time     int64
	// contains filtered or unexported fields
}

type ApplyFunc func(e Event) error

type Encoder interface {
	Encode(v interface{}) ([]byte, error)
	Decode(data []byte, vPtr interface{}) error
}

type Event struct {
	AggregateID   string `json:"aggregateID" dynamodbav:"aggregateID" db:"aggregateID" msg:"a"`
	AggregateType string `json:"aggregateType" dynamodbav:"aggregateType" db:"aggregateType" msg:"b"`
	EventID       string `json:"eventID" dynamodbav:"eventID" db:"eventID" msg:"c"`
	EventType     string `json:"eventType" dynamodbav:"eventType" db:"eventType" msg:"d"`
	Revision      int    `json:"revision" dynamodbav:"revision" db:"revision" msg:"e"`
	Time          int64  `json:"time" dynamodbav:"time" db:"time" msg:"f"`
	Data          []byte `json:"data" dynamodbav:"data" db:"data" msg:"g"`
}

type EventStore interface {
	NewAggregateBase(id string, aggtype string, version int, applyFunc ApplyFunc) *AggregateBase
	GetStream(a Aggregate) error
	GetStreamWithSnapshot(a Aggregate) error
	Commit(a Aggregate) error
	SaveSnapshot(a Aggregate) error
}

type IDGen interface {
	Generate() string
}

type Snapshot struct {
	AggregateID      string `json:"aggregateID" dynamodbav:"aggregateID" db:"aggregateID"`
	AggregateType    string `json:"aggregateType" dynamodbav:"aggregateType" db:"aggregateType"`
	AggregateVersion int    `json:"aggregateVersion" dynamodbav:"aggregateVersion" db:"aggregateVersion"`
	Revision         int    `json:"revision" dynamodbav:"revision" db:"revision"`
	Time             int64  `json:"time" dynamodbav:"time" db:"time"`
	Data             []byte `json:"data" dynamodbav:"data" db:"data"`
}

type Storage interface {
	Save(es []Event) error
	GetLastEvent(id string) ([]Event, error)
	SaveSnapshot(snap *Snapshot) error
	GetSnapshot(id string, version int) (*Snapshot, error)
	GetFromRevision(id string, from int) ([]Event, error)
	GetUndispatchedEvent() ([]Event, error)
	MarkDispatchedEvent(es []Event) error
}

type UUIDV4 struct{}