serializer

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

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

type EventSerializationResult struct {
	Data        []byte
	ContentType string
}

type EventSerializer interface {
	Serialize(event interface{}) (*EventSerializationResult, error)
	Deserialize(data []byte, eventType string, contentType string) (interface{}, error)
	DeserializeType(data []byte, eventType reflect.Type, contentType string) (interface{}, error)
	DeserializeMessage(data []byte, eventType string, contentType string) (interface{}, error)
	DeserializeEvent(data []byte, eventType string, contentType string) (interface{}, error)
	ContentType() string
	Serializer() Serializer
}

type MetadataSerializer interface {
	Serialize(meta metadata.Metadata) ([]byte, error)
	Deserialize(bytes []byte) (metadata.Metadata, error)
}

type Serializer interface {
	Marshal(v interface{}) ([]byte, error)
	Unmarshal(data []byte, v interface{}) error
	UnmarshalFromJson(data string, v interface{}) error
	DecodeWithMapStructure(input interface{}, output interface{}) error
	UnmarshalToMap(data []byte, v *map[string]interface{}) error
	UnmarshalToMapFromJson(data string, v *map[string]interface{}) error
	PrettyPrint(data interface{}) string
	ColoredPrettyPrint(data interface{}) string
}