catalog

Documentation

Index

• type Catalog
• type Registry
  • func NewRegistry(catalog Catalog, tag consul.Tag) *Registry
  • func (r *Registry) Deregister(ctx context.Context, service *core.Service) error
  • func (r *Registry) Fetch(ctx context.Context) (core.Services, error)
  • func (r *Registry) Register(ctx context.Context, service *core.Service) error
  • func (r *Registry) WithLogger(logger core.LoggerInterface)

Types

type Catalog

type Catalog interface {
	Services(*api.QueryOptions) (map[string][]string, *api.QueryMeta, error)
	Service(string, string, *api.QueryOptions) ([]*api.CatalogService, *api.QueryMeta, error)
	Deregister(*api.CatalogDeregistration, *api.WriteOptions) (*api.WriteMeta, error)
	Register(*api.CatalogRegistration, *api.WriteOptions) (*api.WriteMeta, error)
}

Catalog interface provide common function for work with Consul HTTP API /v1/catalog

type Registry

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

Registry is implementation of core.Registry interface

func NewRegistry

func NewRegistry(catalog Catalog, tag consul.Tag) *Registry

NewRegistry provide Registry as core.Registry implementation

func (*Registry) Deregister

func (r *Registry) Deregister(ctx context.Context, service *core.Service) error

Deregister make request for Catalog.Deregister by core.Service RegistrationID

func (*Registry) Fetch

func (r *Registry) Fetch(ctx context.Context) (core.Services, error)

Fetch make request for Catalog.Services plus Catalog.Service and try to cast result to core.Services

func (*Registry) Register

func (r *Registry) Register(ctx context.Context, service *core.Service) error

Register make request for Catalog.Register for core.Service

func (*Registry) WithLogger

func (r *Registry) WithLogger(logger core.LoggerInterface)

WithLogger is implementation of core.Loggable interface