db

type Action struct {
	// Type of the action
	Type ActionType
	// InstanceID of the instance in action
	InstanceID InstanceID
	// CollectionName of the instance in action
	CollectionName string
	// Previous is the instance before the action
	Previous interface{}
	// Current is the instance after the action was done
	Current interface{}
}

type ActionType int

type Event interface {
	Time() []byte
	InstanceID() InstanceID
	Collection() string
}

type EventCodec interface {
	// Reduce applies generated events into state
	Reduce(
		events []Event,
		datastore ds.TxnDatastore,
		baseKey ds.Key,
		indexFunc func(collection string, key ds.Key, oldData, newData []byte, txn ds.Txn) error,
	) ([]ReduceAction, error)
	// Create corresponding events to be dispatched
	Create(ops []Action) ([]Event, format.Node, error)
	// EventsFromBytes deserializes a format.Node bytes payload into
	// Events.
	EventsFromBytes(data []byte) ([]Event, error)
}

type InstanceID string

type ReduceAction struct {
	// Type of the reduced action
	Type ActionType
	// Collection in which action was made
	Collection string
	// InstanceID of the instance in reduced action
	InstanceID InstanceID
}