schema_registry

Documentation

Index

• Constants
• type Schema
• type SchemaRegistry
  • func NewSchemaRegistry(url string) (*SchemaRegistry, error)
  • func (sr *SchemaRegistry) GetSchema(id int32) (string, error)

Constants

const INVALID_SCHEMA = "Invalid Schema"

Types

type Schema

type Schema struct {
	Type    string
	Version string
	Subject string
}

type SchemaRegistry

type SchemaRegistry struct {
	Client schemaregistry.Client
	// contains filtered or unexported fields
}

func NewSchemaRegistry

func NewSchemaRegistry(url string) (*SchemaRegistry, error)

func (*SchemaRegistry) GetSchema

func (sr *SchemaRegistry) GetSchema(id int32) (string, error)