consul

Documentation

Index

• Constants
• Variables
• func NewAgentServiceRegistration(service *vo2.Service) *api.AgentServiceRegistration
• type ConsulRegistry
  • func ConsulInit(c *api.Config) (*ConsulRegistry, error)
  • func (c *ConsulRegistry) Get(ctx context.Context, service *vo2.Service) ([]*vo2.Service, error)
  • func (c *ConsulRegistry) Init(ctx context.Context, f func() error) error
  • func (c *ConsulRegistry) PluginName() string
  • func (c *ConsulRegistry) Register(ctx context.Context, service *vo2.Service) error
  • func (c *ConsulRegistry) SubscribeService(ctx context.Context, service *vo2.Service) error
  • func (c *ConsulRegistry) UnRegister(ctx context.Context, service *vo2.Service) error

Constants

const RegistryName = "consul"

Variables

var ConsulNotFoundErr = errors.New("The client could not be found")

var ConsulRegistionErr = errors.New("Registion failed")

var NacosDeregistionErr = errors.New("Deregistion failed")

var NacosGetServiceErr = errors.New("Nacos get services failed")

var NacosParamErr = errors.New("Registion failed")

var NacosSubscribeErr = errors.New("Nacos subscription failed")

var NacosUnsubscribeErr = errors.New("Nacos Unsubscription failed")

var NacosWeightErr = errors.New("Weight must be lager than 0")

Functions

func NewAgentServiceRegistration

func NewAgentServiceRegistration(service *vo2.Service) *api.AgentServiceRegistration

create agentService

Types

type ConsulRegistry

type ConsulRegistry struct {
	sync.Mutex
	Client   *api.Client
	Services map[string][]*vo2.Service
}

func ConsulInit

func ConsulInit(c *api.Config) (*ConsulRegistry, error)

init consul client

func (*ConsulRegistry) Get

func (c *ConsulRegistry) Get(ctx context.Context, service *vo2.Service) ([]*vo2.Service, error)

get services

func (*ConsulRegistry) Init

func (c *ConsulRegistry) Init(ctx context.Context, f func() error) error

func (*ConsulRegistry) PluginName

func (c *ConsulRegistry) PluginName() string

func (*ConsulRegistry) Register

func (c *ConsulRegistry) Register(ctx context.Context, service *vo2.Service) error

register base

func (*ConsulRegistry) SubscribeService

func (c *ConsulRegistry) SubscribeService(ctx context.Context, service *vo2.Service) error

subscribe Service

func (*ConsulRegistry) UnRegister

func (c *ConsulRegistry) UnRegister(ctx context.Context, service *vo2.Service) error

unregister base