inmemory

var (
	// ErrStreamExistsAlready occurs when create is called for an already created stream
	ErrStreamExistsAlready = errors.New("goengine: stream already exists")
	// ErrStreamNotFound occurs when an unknown streamName is provided
	ErrStreamNotFound = errors.New("goengine: unknown stream")
	// ErrNilMessage occurs when a goengine.Message that is being appended to a stream is nil or a reference to nil
	ErrNilMessage = errors.New("goengine: nil is not a valid message")
)

var (
	// ErrMessageNumberCountMismatch occurs when the provided messages and numbers do not have the same length
	ErrMessageNumberCountMismatch = errors.New("goengine: provided messages and messageNumbers do not match")
	// ErrEventStreamClosed occurs when an eventstream is closed
	ErrEventStreamClosed = errors.New("goengine: no more messages")
	// ErrEventStreamNotStarted occurs when an eventstream Message or MessageNumber is called before Next
	ErrEventStreamNotStarted = errors.New("goengine: eventStream Message called without calling Next")
)

var (
	// ErrTypeMismatch occurs when a metadata value cannot be converted to the constraints value type
	ErrTypeMismatch = errors.New("goengine: the values to compare are of a different type")
	// ErrUnsupportedOperator occurs when a constraints operation is not supported for a type
	ErrUnsupportedOperator = errors.New("goengine: the operator is not supported for this type")
)

var (
	// ErrUnknownPayloadType occurs when a payload type is unknown
	ErrUnknownPayloadType = errors.New("goengine: unknown payload type was provided")
	// ErrDuplicatePayloadType occurs when a payload type is already registered
	ErrDuplicatePayloadType = errors.New("goengine: payload type is already registered")
)

var ErrUnsupportedType = errors.New("the value is not a scalar type")