registry

Documentation

Index

• Constants
• func GetSchemaHandler(r *Registry) gin.HandlerFunc
• func InitializeSchemaCacheBackend(conf config.Backend, b SchemaCacheBackend) error
• func PurgeCacheHandler(r *Registry) gin.HandlerFunc
• type Registry
  • func (r *Registry) Get(key string) (exists bool, data []byte)
  • func (r *Registry) Initialize(conf config.Registry) error
• type SchemaCacheBackend
  • func BuildSchemaCacheBackend(conf config.Backend) (backend SchemaCacheBackend, err error)

Constants

const (
	SCHEMAS_ROUTE     = "/s/"
	CACHE_PURGE_ROUTE = "/c/purge"
	SCHEMA_PARAM      = "schema"
)

Functions

func GetSchemaHandler

func GetSchemaHandler(r *Registry) gin.HandlerFunc

func InitializeSchemaCacheBackend

func InitializeSchemaCacheBackend(conf config.Backend, b SchemaCacheBackend) error

func PurgeCacheHandler

func PurgeCacheHandler(r *Registry) gin.HandlerFunc

Types

type Registry

type Registry struct {
	Cache   *freecache.Cache
	Backend SchemaCacheBackend
	// contains filtered or unexported fields
}

func (*Registry) Get

func (r *Registry) Get(key string) (exists bool, data []byte)

func (*Registry) Initialize

func (r *Registry) Initialize(conf config.Registry) error

type SchemaCacheBackend

type SchemaCacheBackend interface {
	Initialize(config config.Backend) error
	GetRemote(schema string) (contents []byte, err error)
	Close()
}

func BuildSchemaCacheBackend

func BuildSchemaCacheBackend(conf config.Backend) (backend SchemaCacheBackend, err error)