consul

package

v0.2.7 Latest Latest Go to latest Published: Dec 7, 2020 License: MIT Imports: 9 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/archer-plus/core

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Client ¶ added in v0.1.4

func Client() *api.Client

Client 客户端连接对象

func ClientID ¶ added in v0.1.5

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

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

RegisterGRPC GRPC方式注册到consul

Types ¶

type HealthImpl ¶ added in v0.1.7

type HealthImpl struct{}

HealthImpl 健康检查实现

func (*HealthImpl) Check ¶ added in v0.1.7

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

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

func (*HealthImpl) Watch ¶ added in v0.1.7

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注册配置

Source Files ¶

View all Source files

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