schema

Documentation

Index

• func Hash(schema string) string
• type Registry
  • func NewCachedRegistry(registry Registry) Registry
  • func NewConsulSchemaRegistry(client *consul.Client) Registry
  • func NewNoopRegistry() Registry

Functions

func Hash

func Hash(schema string) string

Types

type Registry

type Registry interface {
	// Returns the schema for the given schema key.
	Get(key string) (string, error)

	// Returns the the key of the schema on success.
	Set(schema string) (string, error)

	// Closes all resources.
	Close() error
}

func NewCachedRegistry

func NewCachedRegistry(registry Registry) Registry

func NewConsulSchemaRegistry

func NewConsulSchemaRegistry(client *consul.Client) Registry

func NewNoopRegistry

func NewNoopRegistry() Registry