Documentation
¶
Index ¶
- type Fingerprint
- type Schema
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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)
type SchemaRegistryClient ¶
type SchemaRegistryClient struct {
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient(baseUrl string) *SchemaRegistryClient
func (*SchemaRegistryClient) AutoSerialize ¶
func (*SchemaRegistryClient) Deserialize ¶
func (*SchemaRegistryClient) GetSubjectVersion ¶
func (*SchemaRegistryClient) GetSubjectVersionBySchemaId ¶
func (*SchemaRegistryClient) RegisterSchemaForType ¶
func (c *SchemaRegistryClient) RegisterSchemaForType(ctx context.Context, subject string, protoType protoreflect.Message) (uint32, error)
func (*SchemaRegistryClient) WithTls ¶
func (c *SchemaRegistryClient) WithTls(config *tls.Config) *SchemaRegistryClient
Click to show internal directories.
Click to hide internal directories.