fs

Documentation

Index

• type Adapter
  • func NewAdapter(f fs.FS, dir string) *Adapter
  • func NewDirAdapter(dir string) *Adapter
  • func (f *Adapter) Get(ctx context.Context, id string) (string, error)
  • func (f *Adapter) GetByDefinition(ctx context.Context, schema avro.Schema) (string, error)
  • func (p *Adapter) Persist(ctx context.Context, schema *avro.RecordSchema, ...) (string, error)
  • func (f *Adapter) Walk(ctx context.Context, ...) (int, error)
• type WireFormatter
  • func NewWireFormatter() *WireFormatter
  • func (*WireFormatter) AppendSchemaID(data []byte, id string) ([]byte, error)
  • func (*WireFormatter) ExtractSchemaID(data []byte) (string, []byte, error)

Types

type Adapter

type Adapter struct {
	// contains filtered or unexported fields
}

func NewAdapter

func NewAdapter(f fs.FS, dir string) *Adapter

func NewDirAdapter

func NewDirAdapter(dir string) *Adapter

func (*Adapter) Get

func (f *Adapter) Get(ctx context.Context, id string) (string, error)

Get implements registry.Fetcher.

func (*Adapter) GetByDefinition

func (f *Adapter) GetByDefinition(ctx context.Context, schema avro.Schema) (string, error)

GetByDefinition implements registry.Fetcher.

func (*Adapter) Persist

func (p *Adapter) Persist(ctx context.Context, schema *avro.RecordSchema, opts ...func(*registry.PersistConfig)) (string, error)

Persist implements registry.Persister

func (*Adapter) Walk

func (f *Adapter) Walk(ctx context.Context, fn func(id string, version int64, latest bool, schema *avro.RecordSchema) error, opts ...func(*registry.WalkConfig)) (int, error)

Walk implements registry.Walker.

type WireFormatter

type WireFormatter struct{}

func NewWireFormatter

func NewWireFormatter() *WireFormatter

func (*WireFormatter) AppendSchemaID

func (*WireFormatter) AppendSchemaID(data []byte, id string) ([]byte, error)

AppendSchemaID implements registry.WireFormatter.

func (*WireFormatter) ExtractSchemaID

func (*WireFormatter) ExtractSchemaID(data []byte) (string, []byte, error)

ExtractSchemaID implements registry.WireFormatter.