registry

Documentation

Index

• Variables
• type Fetcher
• type PersistConfig
• type Persister
• type Registry
  • func New(fetcher Fetcher, persister Persister, wf WireFormatter) *Registry
  • func (r *Registry) API() avro.API
  • func (r *Registry) GetCurrent(ctx context.Context, v schemaIDGetter) (schemaID string, schema *avro.RecordSchema, batchSchema *avro.ArraySchema, ...)
  • func (r *Registry) GetSchema(ctx context.Context, id string) (string, *avro.RecordSchema, *avro.ArraySchema, error)
  • func (r *Registry) Setup(ctx context.Context, schema avro.Schema, opts ...func(*RegistryConfig)) error
• type RegistryConfig
• type WalkConfig
• type Walker
• type WireFormatter

Variables

var (
	ErrInvalidSchemaID             = errors.New("invalid schema ID")
	ErrInvalidDataWireFormat       = errors.New("invalid data wire format")
	ErrMarshalOperationUnsupported = errors.New("marshal operation unsupported")
	ErrUnableToResolveSchema       = errors.New("unable to resolve schema")
	ErrUnableToSetupRegistry       = errors.New("unable to setup registry")
	ErrCreateOrUpdateSchemaFailed  = errors.New("failed to create or update schema")
	ErrSchemaNotFound              = errors.New("schema not found")
)

Types

type Fetcher

type Fetcher interface {
	Get(ctx context.Context, id string) (schema string, err error)
	GetByDefinition(ctx context.Context, schema avro.Schema) (id string, err error)
}

type PersistConfig

type PersistConfig struct {
	Resolver func(schema *avro.RecordSchema) (id string, version int, err error)
}

type Persister

type Persister interface {
	Persist(ctx context.Context, schema *avro.RecordSchema, opts ...func(*PersistConfig)) (id string, err error)
}

type Registry

type Registry struct {
	WireFormatter
	// contains filtered or unexported fields
}

func New

func New(fetcher Fetcher, persister Persister, wf WireFormatter) *Registry

func (*Registry) API

func (r *Registry) API() avro.API

API implements Register.

func (*Registry) GetCurrent

func (r *Registry) GetCurrent(ctx context.Context, v schemaIDGetter) (schemaID string, schema *avro.RecordSchema, batchSchema *avro.ArraySchema, err error)

func (*Registry) GetSchema

func (r *Registry) GetSchema(ctx context.Context, id string) (string, *avro.RecordSchema, *avro.ArraySchema, error)

GetSchema implements Register.

func (*Registry) Setup

func (r *Registry) Setup(ctx context.Context, schema avro.Schema, opts ...func(*RegistryConfig)) error

Setup implements Register.

type RegistryConfig

type RegistryConfig struct {
	Namespace      bool
	PersistCurrent bool
}

type WalkConfig

type WalkConfig struct {
	Namespaces []string
}

type Walker

type Walker interface {
	Walk(ctx context.Context, fn func(id string, version int64, latest bool, schema *avro.RecordSchema) error, opts ...func(*WalkConfig)) (int, error)
}

type WireFormatter

type WireFormatter interface {
	ExtractSchemaID(data []byte) (string, []byte, error)
	AppendSchemaID(data []byte, id string) ([]byte, error)
}