registry

README

go-schema-registry-client

Go implementation of ProtoBuf and Avro schema registry client with resolvers and Specific/Generic serialization and deserialization features.

Documentation

Index

• Constants
• type AvroSchema
  • func NewAvroSchema(jsonSchema string) (*AvroSchema, error)
  • func (s *AvroSchema) Render() (string, error)
  • func (s *AvroSchema) Type() string
• type Client
  • func NewClient(baseUrl string) *Client
  • func NewClientWith(config *Config) *Client
  • func (c *Client) Deserialize(ctx context.Context, data []byte) (interface{}, error)
  • func (c *Client) DeserializeInto(ctx context.Context, data []byte, into interface{}) error
  • func (c *Client) GetSchema(ctx context.Context, schemaId uint32) (Schema, error)
  • func (c *Client) GetSubjectVersion(ctx context.Context, subject string, version int) (Schema, error)
  • func (c *Client) GetSubjectVersionBySchemaId(ctx context.Context, subject string, schemaId uint32) (int, error)
  • func (c *Client) RegisterAvroType(ctx context.Context, subject string, schema avro.Schema) (uint32, error)
  • func (c *Client) RegisterProtobufType(ctx context.Context, subject string, protoType protoreflect.Message) (uint32, error)
  • func (c *Client) Serialize(ctx context.Context, subject string, value interface{}) ([]byte, error)
• type Config
  • func (c *Config) AddCaCert(caPemFile string) error
  • func (c *Config) AddClientCert(certFile, keyFile, keyPass string) error
  • func (c *Config) LogCaches() bool
  • func (c *Config) LogEntities() bool
  • func (c *Config) LogHttp() bool
  • func (c *Config) LogWarnings() bool
• type LogLevel
• type ProtobufSchema
  • func NewProtobufSchema(d protoreflect.FileDescriptor) (*ProtobufSchema, error)
  • func (s *ProtobufSchema) Print()
  • func (s *ProtobufSchema) Render() (string, error)
  • func (s *ProtobufSchema) Type() string
• type Schema

Constants

const LogEntities = 128

Types

type AvroSchema

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

func NewAvroSchema

func NewAvroSchema(jsonSchema string) (*AvroSchema, error)

func (*AvroSchema) Render

func (s *AvroSchema) Render() (string, error)

func (*AvroSchema) Type

func (s *AvroSchema) Type() string

type Client

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

func NewClient

func NewClient(baseUrl string) *Client

func NewClientWith

func NewClientWith(config *Config) *Client

func (*Client) Deserialize

func (c *Client) Deserialize(ctx context.Context, data []byte) (interface{}, error)

func (*Client) DeserializeInto

func (c *Client) DeserializeInto(ctx context.Context, data []byte, into interface{}) error

func (*Client) GetSchema

func (c *Client) GetSchema(ctx context.Context, schemaId uint32) (Schema, error)

func (*Client) GetSubjectVersion

func (c *Client) GetSubjectVersion(ctx context.Context, subject string, version int) (Schema, error)

func (*Client) GetSubjectVersionBySchemaId

func (c *Client) GetSubjectVersionBySchemaId(ctx context.Context, subject string, schemaId uint32) (int, error)

func (*Client) RegisterAvroType

func (c *Client) RegisterAvroType(ctx context.Context, subject string, schema avro.Schema) (uint32, error)

func (*Client) RegisterProtobufType

func (c *Client) RegisterProtobufType(ctx context.Context, subject string, protoType protoreflect.Message) (uint32, error)

func (*Client) Serialize

func (c *Client) Serialize(ctx context.Context, subject string, value interface{}) ([]byte, error)

type Config

type Config struct {
	LogLevel LogLevel
	Tls      *tls.Config
	Url      string
}

func (*Config) AddCaCert

func (c *Config) AddCaCert(caPemFile string) error

func (*Config) AddClientCert

func (c *Config) AddClientCert(certFile, keyFile, keyPass string) error

func (*Config) LogCaches

func (c *Config) LogCaches() bool

func (*Config) LogEntities

func (c *Config) LogEntities() bool

func (*Config) LogHttp

func (c *Config) LogHttp() bool

func (*Config) LogWarnings

func (c *Config) LogWarnings() bool

type LogLevel

type LogLevel uint32

const LogCaches LogLevel = 4

const LogEverything LogLevel = 255

const LogHttp LogLevel = 2

const LogNothing LogLevel = 0

const LogWarnings LogLevel = 1

type ProtobufSchema

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

func NewProtobufSchema

func NewProtobufSchema(d protoreflect.FileDescriptor) (*ProtobufSchema, error)

func (*ProtobufSchema) Print

func (s *ProtobufSchema) Print()

func (*ProtobufSchema) Render

func (s *ProtobufSchema) Render() (string, error)

func (*ProtobufSchema) Type

func (s *ProtobufSchema) Type() string

type Schema

type Schema interface {
	Render() (string, error)
	Type() string
}