json

Documentation

Index

• func ColoredPrettyPrint(data interface{}) string
• func DecodeWithMapStructure(input interface{}, output interface{}) error
• func Marshal(v interface{}) ([]byte, error)
• func NewDefaultEventJsonSerializer(serializer serializer.Serializer) serializer.EventSerializer
• func NewDefaultJsonSerializer() serializer.Serializer
• func NewDefaultMessageJsonSerializer(s serializer.Serializer) serializer.MessageSerializer
• func NewDefaultMetadataJsonSerializer(serializer serializer.Serializer) serializer.MetadataSerializer
• func PrettyPrint(data interface{}) string
• func Unmarshal(data []byte, v interface{}) error
• func UnmarshalFromJSON(data string, v interface{}) error
• func UnmarshalToMap(data []byte, v *map[string]interface{}) error
• func UnmarshalToMapFromJson(data string, v *map[string]interface{}) error
• type DefaultEventJsonSerializer
  • func (s *DefaultEventJsonSerializer) ContentType() string
  • func (s *DefaultEventJsonSerializer) Deserialize(data []byte, eventType string, contentType string) (domain.IDomainEvent, error)
  • func (s *DefaultEventJsonSerializer) DeserializeObject(data []byte, eventType string, contentType string) (interface{}, error)
  • func (s *DefaultEventJsonSerializer) DeserializeType(data []byte, eventType reflect.Type, contentType string) (domain.IDomainEvent, error)
  • func (s *DefaultEventJsonSerializer) Serialize(event domain.IDomainEvent) (*serializer.EventSerializationResult, error)
  • func (s *DefaultEventJsonSerializer) SerializeObject(event interface{}) (*serializer.EventSerializationResult, error)
  • func (s *DefaultEventJsonSerializer) Serializer() serializer.Serializer
• type DefaultMessageJsonSerializer
  • func (m *DefaultMessageJsonSerializer) ContentType() string
  • func (m *DefaultMessageJsonSerializer) Deserialize(data []byte, messageType string, contentType string) (types.IMessage, error)
  • func (m *DefaultMessageJsonSerializer) DeserializeObject(data []byte, messageType string, contentType string) (interface{}, error)
  • func (m *DefaultMessageJsonSerializer) DeserializeType(data []byte, messageType reflect.Type, contentType string) (types.IMessage, error)
  • func (m *DefaultMessageJsonSerializer) Serialize(message types.IMessage) (*serializer.EventSerializationResult, error)
  • func (m *DefaultMessageJsonSerializer) SerializeEnvelop(messageEnvelop types.MessageEnvelope) (*serializer.EventSerializationResult, error)
  • func (m *DefaultMessageJsonSerializer) SerializeObject(message interface{}) (*serializer.EventSerializationResult, error)
  • func (m *DefaultMessageJsonSerializer) Serializer() serializer.Serializer
• type DefaultMetadataJsonSerializer
  • func (s *DefaultMetadataJsonSerializer) Deserialize(bytes []byte) (metadata.Metadata, error)
  • func (s *DefaultMetadataJsonSerializer) Serialize(meta metadata.Metadata) ([]byte, error)

Functions

func ColoredPrettyPrint

func ColoredPrettyPrint(data interface{}) string

func DecodeWithMapStructure

func DecodeWithMapStructure(
	input interface{},
	output interface{},
) error

DecodeWithMapStructure is a wrapper around mapstructure.Decode. Decode takes an input structure or map[string]interface{} and uses reflection to translate it to the output structure. output must be a pointer to a map or struct. https://pkg.go.dev/github.com/mitchellh/mapstructure#section-readme

func Marshal

func Marshal(v interface{}) ([]byte, error)

func NewDefaultEventJsonSerializer

func NewDefaultEventJsonSerializer(serializer serializer.Serializer) serializer.EventSerializer

func NewDefaultJsonSerializer

func NewDefaultJsonSerializer() serializer.Serializer

func NewDefaultMessageJsonSerializer

func NewDefaultMessageJsonSerializer(s serializer.Serializer) serializer.MessageSerializer

func NewDefaultMetadataJsonSerializer

func NewDefaultMetadataJsonSerializer(serializer serializer.Serializer) serializer.MetadataSerializer

func PrettyPrint

func PrettyPrint(data interface{}) string

func Unmarshal

func Unmarshal(data []byte, v interface{}) error

Unmarshal is a wrapper around json.Unmarshal. To unmarshal JSON into an interface value, Unmarshal stores in a map[string]interface{}

func UnmarshalFromJSON

func UnmarshalFromJSON(data string, v interface{}) error

UnmarshalFromJSON is a wrapper around json.Unmarshal.

func UnmarshalToMap

func UnmarshalToMap(
	data []byte,
	v *map[string]interface{},
) error

func UnmarshalToMapFromJson

func UnmarshalToMapFromJson(
	data string,
	v *map[string]interface{},
) error

Types

type DefaultEventJsonSerializer

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

func (*DefaultEventJsonSerializer) ContentType

func (s *DefaultEventJsonSerializer) ContentType() string

func (*DefaultEventJsonSerializer) Deserialize

func (s *DefaultEventJsonSerializer) Deserialize(
	data []byte,
	eventType string,
	contentType string,
) (domain.IDomainEvent, error)

func (*DefaultEventJsonSerializer) DeserializeObject

func (s *DefaultEventJsonSerializer) DeserializeObject(
	data []byte,
	eventType string,
	contentType string,
) (interface{}, error)

func (*DefaultEventJsonSerializer) DeserializeType

func (s *DefaultEventJsonSerializer) DeserializeType(
	data []byte,
	eventType reflect.Type,
	contentType string,
) (domain.IDomainEvent, error)

func (*DefaultEventJsonSerializer) Serialize

func (s *DefaultEventJsonSerializer) Serialize(event domain.IDomainEvent) (*serializer.EventSerializationResult, error)

func (*DefaultEventJsonSerializer) SerializeObject

func (s *DefaultEventJsonSerializer) SerializeObject(event interface{}) (*serializer.EventSerializationResult, error)

func (*DefaultEventJsonSerializer) Serializer

func (s *DefaultEventJsonSerializer) Serializer() serializer.Serializer

type DefaultMessageJsonSerializer

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

func (*DefaultMessageJsonSerializer) ContentType

func (m *DefaultMessageJsonSerializer) ContentType() string

func (*DefaultMessageJsonSerializer) Deserialize

func (m *DefaultMessageJsonSerializer) Deserialize(
	data []byte,
	messageType string,
	contentType string,
) (types.IMessage, error)

func (*DefaultMessageJsonSerializer) DeserializeObject

func (m *DefaultMessageJsonSerializer) DeserializeObject(
	data []byte,
	messageType string,
	contentType string,
) (interface{}, error)

func (*DefaultMessageJsonSerializer) DeserializeType

func (m *DefaultMessageJsonSerializer) DeserializeType(
	data []byte,
	messageType reflect.Type,
	contentType string,
) (types.IMessage, error)

func (*DefaultMessageJsonSerializer) Serialize

func (m *DefaultMessageJsonSerializer) Serialize(message types.IMessage) (*serializer.EventSerializationResult, error)

func (*DefaultMessageJsonSerializer) SerializeEnvelop

func (m *DefaultMessageJsonSerializer) SerializeEnvelop(
	messageEnvelop types.MessageEnvelope,
) (*serializer.EventSerializationResult, error)

func (*DefaultMessageJsonSerializer) SerializeObject

func (m *DefaultMessageJsonSerializer) SerializeObject(
	message interface{},
) (*serializer.EventSerializationResult, error)

func (*DefaultMessageJsonSerializer) Serializer

func (m *DefaultMessageJsonSerializer) Serializer() serializer.Serializer

type DefaultMetadataJsonSerializer

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

func (*DefaultMetadataJsonSerializer) Deserialize

func (s *DefaultMetadataJsonSerializer) Deserialize(bytes []byte) (metadata.Metadata, error)

func (*DefaultMetadataJsonSerializer) Serialize

func (s *DefaultMetadataJsonSerializer) Serialize(meta metadata.Metadata) ([]byte, error)