schema_registry

README

go-schema-registry-client

ProtoBuf native implementation of the schema registry

TODO

• port avro features from go-connect
• turn-off all logging and rely on well-formatted errors

Documentation

Index

• type Client
  • func NewClient(baseUrl string) *Client
  • func (c *Client) AutoSerialize(ctx context.Context, subject string, value proto.Message) ([]byte, error)
  • func (c *Client) Deserialize(ctx context.Context, data []byte) (proto.Message, 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) RegisterSchemaForType(ctx context.Context, subject string, protoType protoreflect.Message) (uint32, error)
  • func (c *Client) Serialize(schemaId uint32, value proto.Message) ([]byte, error)
  • func (c *Client) WithTls(config *tls.Config) *Client
• type Fingerprint
  • func (f *Fingerprint) Equal(other *Fingerprint) bool
• type Schema
  • func NewSchema(d protoreflect.FileDescriptor) (*Schema, error)
  • func (s Schema) Fingerprint() (*Fingerprint, error)

Types

type Client

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

func NewClient

func NewClient(baseUrl string) *Client

func (*Client) AutoSerialize

func (c *Client) AutoSerialize(ctx context.Context, subject string, value proto.Message) ([]byte, error)

func (*Client) Deserialize

func (c *Client) Deserialize(ctx context.Context, data []byte) (proto.Message, 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) RegisterSchemaForType

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

func (*Client) Serialize

func (c *Client) Serialize(schemaId uint32, value proto.Message) ([]byte, error)

func (*Client) WithTls

func (c *Client) WithTls(config *tls.Config) *Client

type Fingerprint

type Fingerprint [32]byte

func (*Fingerprint) Equal

func (f *Fingerprint) Equal(other *Fingerprint) bool

type Schema

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

func NewSchema

func NewSchema(d protoreflect.FileDescriptor) (*Schema, error)

func (Schema) Fingerprint

func (s Schema) Fingerprint() (*Fingerprint, error)