schema_registry

README

go-schema-registry-client

ProtoBuf native implementation of the schema registry

Documentation

Index

• type AvroSchema
  • func (s *AvroSchema) Render() (string, error)
  • func (s *AvroSchema) Type() string
• type Client
  • func NewClient(baseUrl string) *Client
  • func NewClientWithTls(baseUrl string, config *tls.Config) *Client
  • func (c *Client) Deserialize(ctx context.Context, data []byte) (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 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

Types

type AvroSchema

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

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 NewClientWithTls

func NewClientWithTls(baseUrl string, config *tls.Config) *Client

func (*Client) Deserialize

func (c *Client) Deserialize(ctx context.Context, data []byte) (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 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 {
	//Fingerprint() (*Fingerprint, error)
	Render() (string, error)
	Type() string
}