schemaregistry

Apr 4, 2020

Changes in this version

type Registry

+ func (r *Registry) Print()

Mar 19, 2020

Changes in this version

+ type Encoder struct

+ func NewEncoder(reg *Registry, subject *Subject) (*Encoder, error)

+ func NewGenericEncoder(reg *Registry) (*Encoder, error)

+ func (s *Encoder) Decode(data []byte) (interface{}, error)

+ func (s *Encoder) Encode(data interface{}) ([]byte, error)

+ func (s *Encoder) Schema() string

+ type GenericEncoder struct

+ func (s *GenericEncoder) Decode(data []byte) (interface{}, error)

+ func (s *GenericEncoder) Encode(data interface{}) ([]byte, error)

+ func (s *GenericEncoder) Schema() string

+ type Option func(*options)

+ func WithBackgroundSync(bootstrapServers []string, storageTopic string) Option

+ func WithLogger(logger log.Logger) Option

+ type Registry struct

+ func NewRegistry(url string, opts ...Option) (*Registry, error)

+ func (r *Registry) GenericEncoder() *GenericEncoder

+ func (r *Registry) Register(subject string, version int, decoder jsonDecoder) error

+ func (r *Registry) Sync() error

+ func (r *Registry) WithLatestSchema(subject string) *Encoder

+ func (r *Registry) WithSchema(subject string, version int) *Encoder

+ type Subject struct

+ Id int

+ JsonDecoder jsonDecoder

+ Schema string

+ Subject string

+ Version int

+ type Version int

+ const VersionAll

+ const VersionLatest

+ func (v Version) String() string