schema

Documentation

Index

• Constants
• Variables
• func Create(ctx context.Context, typ schema.Type, subject string, bytes []byte) (schema.Schema, error)
• func Get(ctx context.Context, subject string, version int) (schema.Schema, error)
• type InMemoryService
  • func NewInMemoryService() *InMemoryService
  • func (s *InMemoryService) CreateSchema(_ context.Context, request pprocutils.CreateSchemaRequest) (pprocutils.CreateSchemaResponse, error)
  • func (s *InMemoryService) GetSchema(_ context.Context, request pprocutils.GetSchemaRequest) (pprocutils.GetSchemaResponse, error)

Constants

const TypeAvro = schema.TypeAvro

Variables

var (
	ErrSubjectNotFound = pprocutils.ErrSubjectNotFound
	ErrVersionNotFound = pprocutils.ErrVersionNotFound
	ErrInvalidSchema   = pprocutils.ErrInvalidSchema
)

var SchemaService pprocutils.SchemaService = newCachedSchemaService(NewInMemoryService())

Functions

func Create

func Create(ctx context.Context, typ schema.Type, subject string, bytes []byte) (schema.Schema, error)

func Get

func Get(ctx context.Context, subject string, version int) (schema.Schema, error)

Types

type InMemoryService

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

func NewInMemoryService

func NewInMemoryService() *InMemoryService

func (*InMemoryService) CreateSchema

func (s *InMemoryService) CreateSchema(_ context.Context, request pprocutils.CreateSchemaRequest) (pprocutils.CreateSchemaResponse, error)

func (*InMemoryService) GetSchema

func (s *InMemoryService) GetSchema(_ context.Context, request pprocutils.GetSchemaRequest) (pprocutils.GetSchemaResponse, error)