registry

Jan 3, 2021

Changes in this version

type Config

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

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

Jan 3, 2021

Changes in this version

type AvroSchema

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

Dec 30, 2020

Changes in this version

+ const LogEntities

type Config

+ func (c *Config) LogEntities() bool

Dec 30, 2020

Changes in this version

type Client

+ func NewClientWith(config *Config) *Client

type Config

+ Url string

Dec 30, 2020

Changes in this version

+ type Config struct

+ LogLevel LogLevel

+ Tls *tls.Config

+ func (c *Config) LogCaches() bool

+ func (c *Config) LogHttp() bool

+ func (c *Config) LogWarnings() bool

+ type LogLevel uint32

+ const LogCaches

+ const LogEverything

+ const LogHttp

+ const LogNothing

+ const LogWarnings

Dec 29, 2020

Changes in this version

type Client

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

Dec 29, 2020

Changes in this version

type ProtobufSchema

+ func (s *ProtobufSchema) Print()

Dec 28, 2020

Changes in this version

+ type AvroSchema struct

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

+ func (s *AvroSchema) Type() string

type Client

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

+ 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)

+ type ProtobufSchema struct

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

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

+ func (s *ProtobufSchema) Type() string

type Schema

+ Render func() (string, error)

+ Type func() string

Dec 28, 2020

Changes in this version

+ type Client struct

+ 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 Schema

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

Dec 28, 2020

Changes in this version

+ type Fingerprint [32]byte

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

+ type Schema struct

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

+ type SchemaRegistryClient struct

+ func NewClient(baseUrl string) *SchemaRegistryClient

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

+ func (c *SchemaRegistryClient) Deserialize(ctx context.Context, data []byte) (proto.Message, error)

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

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

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

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

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

+ func (c *SchemaRegistryClient) WithTls(config *tls.Config) *SchemaRegistryClient