avroturf

package module

v0.0.1 Latest Latest Go to latest Published: Feb 5, 2021 License: MIT Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/wanabe/avroturf-go

Links

Open Source Insights

README ¶

avroturf-go

avroturf-go is a library for the Apache Avro serialization format. This library is intended to be a very partial port of AvroTurf.

Usage

Please refer integration_test.go.

Documentation ¶

Index ¶

Variables
type CachedConfluentSchemaRegistry
- func (r *CachedConfluentSchemaRegistry) FetchSchema(schemaID uint32) (avro.Schema, error)
- func (r *CachedConfluentSchemaRegistry) Register(subject string, schema avro.Schema) (uint32, error)
type ConfluentSchemaRegistry
- func (r *ConfluentSchemaRegistry) FetchSchema(schemaID uint32) (avro.Schema, error)
- func (r *ConfluentSchemaRegistry) Register(subject string, schema avro.Schema) (uint32, error)
type InMemoryCache
- func NewInMemoryCache() *InMemoryCache
type Messaging
- func NewMessaging(namespace string, path string, registryURL string) *Messaging
type SchemaRegistry
type SchemaStore
- func NewSchemaStore(path string) *SchemaStore
- func (store *SchemaStore) Find(schemaName string, namespace string) (avro.Schema, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var HTTPClient httpClient

View Source

var Logger *log.Logger

Functions ¶

This section is empty.

Types ¶

type CachedConfluentSchemaRegistry ¶

type CachedConfluentSchemaRegistry struct {
	Upstream *ConfluentSchemaRegistry
	Cache    *InMemoryCache
}

func (*CachedConfluentSchemaRegistry) FetchSchema ¶

func (r *CachedConfluentSchemaRegistry) FetchSchema(schemaID uint32) (avro.Schema, error)

func (*CachedConfluentSchemaRegistry) Register ¶

func (r *CachedConfluentSchemaRegistry) Register(subject string, schema avro.Schema) (uint32, error)

type ConfluentSchemaRegistry ¶

type ConfluentSchemaRegistry struct {
	RegistryURL string
}

func (*ConfluentSchemaRegistry) FetchSchema ¶

func (r *ConfluentSchemaRegistry) FetchSchema(schemaID uint32) (avro.Schema, error)

func (*ConfluentSchemaRegistry) Register ¶

func (r *ConfluentSchemaRegistry) Register(subject string, schema avro.Schema) (uint32, error)

type InMemoryCache ¶

type InMemoryCache struct {
	SchemasByID             map[uint32]avro.Schema
	IdsBySchema             map[string]uint32
	SchemasBySubjectVersion map[string]avro.Schema
}

func NewInMemoryCache ¶

func NewInMemoryCache() *InMemoryCache

func (*InMemoryCache) LookupIdBySchema ¶

func (c *InMemoryCache) LookupIdBySchema(subject string, schema avro.Schema) uint32

func (*InMemoryCache) LookupSchemaByID ¶

func (c *InMemoryCache) LookupSchemaByID(schemaID uint32) avro.Schema

func (*InMemoryCache) StoreIdBySchema ¶

func (c *InMemoryCache) StoreIdBySchema(subject string, schema avro.Schema, schemaID uint32) uint32

func (*InMemoryCache) StoreSchemaByID ¶

func (c *InMemoryCache) StoreSchemaByID(schemaID uint32, schema avro.Schema) avro.Schema

type Messaging ¶

type Messaging struct {
	sync.Mutex
	NameSpace   string
	SchemaStore *SchemaStore
	Registry    SchemaRegistry
	SchemasByID map[uint32]avro.Schema
}

func NewMessaging ¶

func NewMessaging(namespace string, path string, registryURL string) *Messaging

func (*Messaging) Decode ¶

func (m *Messaging) Decode(data []byte, obj interface{}) error

func (*Messaging) DecodeByLocalSchema ¶

func (m *Messaging) DecodeByLocalSchema(data []byte, obj interface{}, schemaName string, namespace string) error

func (*Messaging) Encode ¶

func (m *Messaging) Encode(obj interface{}, subject string, schemaName string, namespace string) ([]byte, error)

func (*Messaging) EncodeByLocalSchema ¶

func (m *Messaging) EncodeByLocalSchema(obj interface{}, schemaName string, namespace string, schemaID uint32) ([]byte, error)

func (*Messaging) GetRecordSchema ¶

func (m *Messaging) GetRecordSchema(data []byte) (*avro.RecordSchema, error)

func (*Messaging) GetSchema ¶

func (m *Messaging) GetSchema(data []byte) (avro.Schema, error)

func (*Messaging) RegisterSchema ¶

func (m *Messaging) RegisterSchema(subject string, schemaName string, namespace string) (uint32, avro.Schema, error)

type SchemaRegistry ¶

type SchemaRegistry interface {
	FetchSchema(schemaID uint32) (avro.Schema, error)
	Register(subject string, schema avro.Schema) (uint32, error)
}

type SchemaStore ¶

type SchemaStore struct {
	sync.Mutex
	Path string
	// contains filtered or unexported fields
}

func NewSchemaStore ¶

func NewSchemaStore(path string) *SchemaStore

func (*SchemaStore) Find ¶

func (store *SchemaStore) Find(schemaName string, namespace string) (avro.Schema, error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
mock_avroturf Package mock_avroturf is a generated GoMock package.	Package mock_avroturf is a generated GoMock package.

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL