The highest tagged major version is
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AggregateChangedFactory ¶
type AggregateChangedFactory struct {
// contains filtered or unexported fields
}
AggregateChangedFactory reconstructs aggregate.Changed messages
func NewAggregateChangedFactory ¶
func NewAggregateChangedFactory(factory goengine.MessagePayloadFactory) (*AggregateChangedFactory, error)
NewAggregateChangedFactory returns a new instance of an AggregateChangedFactory
func (*AggregateChangedFactory) CreateEventStream ¶
func (f *AggregateChangedFactory) CreateEventStream(rows *sql.Rows) (goengine.EventStream, error)
CreateEventStream reconstruct the aggregate.Changed messages from the sql.Rows
type InvalidMetadataValueTypeError ¶
type InvalidMetadataValueTypeError struct {
// contains filtered or unexported fields
}
InvalidMetadataValueTypeError is an error indicating the value metadata key was an unexpected type.
func (*InvalidMetadataValueTypeError) Error ¶
func (e *InvalidMetadataValueTypeError) Error() string
type MissingMetadataError ¶
type MissingMetadataError string
MissingMetadataError is an error indicating the requested metadata was nil.
func (MissingMetadataError) Error ¶
func (e MissingMetadataError) Error() string
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.