consul

package

v0.4.0 Latest Latest Go to latest Published: Jan 26, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/sq325/kitComplement

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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 ¶ added in v0.4.0

func NewService(svc *Service) *Service

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL