consul

Documentation

Index

• Constants
• func DiscoveryServices(serviceName string, q *consul.QueryOptions) ([]consul.AgentServiceChecksInfo, error)
• func InitConsulClient()
• func RegisterGrpcConsul(serviceStruct ServiceConsul) error
• func RegisterWebConsul(serviceStruct ServiceConsul) error
• func UnRegisterConsul(serviceId string)
• type Resolver
  • func NewResolver(serviceName string, logger *zap.Logger) *Resolver
  • func (r *Resolver) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (r *Resolver) Close()
  • func (r *Resolver) ResolveNow(o resolver.ResolveNowOptions)
  • func (r *Resolver) Scheme() string
• type ServiceConsul

Constants

const (
	DataEmptyError = "data find empty"
)

Functions

func DiscoveryServices

func DiscoveryServices(serviceName string, q *consul.QueryOptions) ([]consul.AgentServiceChecksInfo, error)

func InitConsulClient

func InitConsulClient()

func RegisterGrpcConsul

func RegisterGrpcConsul(serviceStruct ServiceConsul) error

func RegisterWebConsul

func RegisterWebConsul(serviceStruct ServiceConsul) error

func UnRegisterConsul

func UnRegisterConsul(serviceId string)

Types

type Resolver

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

Resolver for grpc client

func NewResolver

func NewResolver(serviceName string, logger *zap.Logger) *Resolver

NewResolver create a new resolver.Builder base on etcd

func (*Resolver) Build

func (r *Resolver) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

Build creates a new resolver.Resolver for the given target

func (*Resolver) Close

func (r *Resolver) Close()

Close resolver.Resolver interface

func (*Resolver) ResolveNow

func (r *Resolver) ResolveNow(o resolver.ResolveNowOptions)

ResolveNow resolver.Resolver interface

func (*Resolver) Scheme

func (r *Resolver) Scheme() string

Scheme returns the scheme supported by this resolver.

type ServiceConsul

type ServiceConsul struct {
	Id       string
	Name     string
	Port     int
	Address  string
	IsSecure bool
}