agent

Documentation

Index

• type Agent
• type Registry
  • func NewRegistry(agent Agent, tag consul.Tag) *Registry
  • func (r *Registry) Deregister(ctx context.Context, service *core.Service) error
  • func (r *Registry) Fetch(_ 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 Agent

type Agent interface {
	ServicesWithFilter(filter string) (map[string]*api.AgentService, error)
	ServiceRegister(service *api.AgentServiceRegistration) error
	ServiceDeregister(serviceID string) error
}

Agent interface provide common function for work with Consul HTTP API

type Registry

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

Registry is implementation of core.Registry interface

func NewRegistry

func NewRegistry(agent Agent, 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 Agent.ServiceDeregister by core.Service RegistrationID

func (*Registry) Fetch

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

Fetch make request for Agent.Services 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 Agent.ServiceRegister for core.Service

func (*Registry) WithLogger

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

WithLogger is implementation of core.Loggable interface