consul

Documentation

Index

• func Client() *api.Client
• func ClientID() string
• func Deregister()
• func Init(address string)
• func Register(config *RegisterConfig)
• func RegisterGRPC(config *RegisterConfig, svc *grpc.Server)
• type HealthImpl
  • func (h *HealthImpl) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (h *HealthImpl) Watch(request *grpc_health_v1.HealthCheckRequest, ...) error
• type RegisterConfig

Functions

func Client

func Client() *api.Client

Client 客户端连接对象

func ClientID

func ClientID() string

ClientID 客户端唯一编号

func Deregister

func Deregister()

Deregister 反注册

func Init

func Init(address string)

Init 初始化服务注册

func Register

func Register(config *RegisterConfig)

Register 注册到consul

func RegisterGRPC

func RegisterGRPC(config *RegisterConfig, svc *grpc.Server)

RegisterGRPC GRPC方式注册到consul

Types

type HealthImpl

type HealthImpl struct{}

HealthImpl 健康检查实现

func (*HealthImpl) Check

func (h *HealthImpl) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

Check 实现健康检查接口，这里直接返回健康状态，这里也可以有更复杂的健康检查策略，比如根据服务器负载来返回

func (*HealthImpl) Watch

func (h *HealthImpl) Watch(request *grpc_health_v1.HealthCheckRequest, server grpc_health_v1.Health_WatchServer) error

Watch 流式检测

type RegisterConfig

type RegisterConfig struct {
	ServiceName                    string        // 服务显示名称
	ServiceAddress                 string        // consul IP地址
	ServicePort                    int           // 端口
	Tags                           []string      // 标签
	Interval                       time.Duration // 健康检查时间间隔(单位秒)
	DeregisterCriticalServiceAfter time.Duration
}

RegisterConfig consul注册配置