jsonschema

Documentation

Index

• type Deserializer
  • func NewDeserializer(client schemaregistry.Client, serdeType serde.Type, conf *DeserializerConfig) (*Deserializer, error)
  • func (s *Deserializer) Deserialize(topic string, payload []byte) (interface{}, error)
  • func (s *Deserializer) DeserializeInto(topic string, payload []byte, msg interface{}) error
• type DeserializerConfig
  • func NewDeserializerConfig() *DeserializerConfig
• type Serializer
  • func NewSerializer(client schemaregistry.Client, serdeType serde.Type, conf *SerializerConfig) (*Serializer, error)
  • func (s *Serializer) Serialize(topic string, msg interface{}) ([]byte, error)
• type SerializerConfig
  • func NewSerializerConfig() *SerializerConfig

Types

type Deserializer

type Deserializer struct {
	serde.BaseDeserializer
	// contains filtered or unexported fields
}

Deserializer represents a JSON Schema deserializer

func NewDeserializer

func NewDeserializer(client schemaregistry.Client, serdeType serde.Type, conf *DeserializerConfig) (*Deserializer, error)

NewDeserializer creates a JSON deserializer for generic objects

func (*Deserializer) Deserialize

func (s *Deserializer) Deserialize(topic string, payload []byte) (interface{}, error)

Deserialize implements deserialization of generic data from JSON

func (*Deserializer) DeserializeInto

func (s *Deserializer) DeserializeInto(topic string, payload []byte, msg interface{}) error

DeserializeInto implements deserialization of generic data from JSON to the given object

type DeserializerConfig

type DeserializerConfig struct {
	serde.DeserializerConfig
	EnableValidation bool
}

DeserializerConfig is used to pass multiple configuration options to the deserializers.

func NewDeserializerConfig

func NewDeserializerConfig() *DeserializerConfig

NewDeserializerConfig returns a new configuration instance with sane defaults.

type Serializer

type Serializer struct {
	serde.BaseSerializer
	// contains filtered or unexported fields
}

Serializer represents a JSON Schema serializer

func NewSerializer

func NewSerializer(client schemaregistry.Client, serdeType serde.Type, conf *SerializerConfig) (*Serializer, error)

NewSerializer creates a JSON serializer for generic objects

func (*Serializer) Serialize

func (s *Serializer) Serialize(topic string, msg interface{}) ([]byte, error)

Serialize implements serialization of generic data to JSON

type SerializerConfig

type SerializerConfig struct {
	serde.SerializerConfig
	// EnableValidation enables validation of the JSON against the schema.
	EnableValidation bool
}

SerializerConfig is used to pass multiple configuration options to the serializers.

func NewSerializerConfig

func NewSerializerConfig() *SerializerConfig

NewSerializerConfig returns a new configuration instance with sane defaults.