consul

Documentation

Index

• func FactoryFor(enc kithttp.EncodeRequestFunc, dec kithttp.DecodeResponseFunc, path string) sd.Factory
• func NewConsulClient(consulIP string, consulPort int) consulsd.Client
• func NewEp(consulClient consulsd.Client, logger log.Logger, svcName string, ...) endpoint.Endpoint
• func NewLogger() (logger log.Logger)
• type Cataloger
• type Registrar
  • func NewRegistrar(consulClient consulsd.Client, logger log.Logger) Registrar
• type Service
  • func NewService(svc *Service) *Service

Functions

func FactoryFor

func FactoryFor(enc kithttp.EncodeRequestFunc, dec kithttp.DecodeResponseFunc, path string) sd.Factory

factor: url -> endpoint instance: ip:port path: /search

func NewConsulClient

func NewConsulClient(consulIP string, consulPort int) consulsd.Client

func NewEp

func NewEp(consulClient consulsd.Client, logger log.Logger, svcName string, dec kithttp.DecodeResponseFunc, path string) endpoint.Endpoint

func NewLogger

func NewLogger() (logger log.Logger)

Types

type Cataloger

type Cataloger interface {
	// Service
	Services() []*Service
}

type Registrar

type Registrar interface {
	Register(svc *Service)
	Deregister(svc *Service)
}

func NewRegistrar

func NewRegistrar(consulClient consulsd.Client, logger log.Logger) Registrar

type Service

type Service struct {
	Name  string
	ID    string // default is svcName_UUID
	IP    string // svc ip, default hostAdmIp
	Port  int    // svc port
	Tags  []string
	Check struct {
		Path     string // default /health
		Interval string // "60s"
		Timeout  string // "10s"
	}
}

func NewService

func NewService(svc *Service) *Service