consul_api

package

v0.0.0-...-b988991 Latest Latest Go to latest Published: Apr 16, 2024 License: MIT Imports: 6 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/wubo0067/calmwu-go

Links

Open Source Insights

Documentation ¶

Overview ¶

* @Author: calmwu * @Date: 2017-11-21 14:52:04 * @Last Modified by: calmwu * @Last Modified time: 2017-11-21 17:27:18 * @Comment:

Index ¶

Variables
func ConsulGlobalLock(client *api.Client, lockName string, watiLockTime string) (*api.Lock, error)
func ConsulGlobalSeq(client *api.Client, seqName string, initSeqNum int, waitTime string) (int, error)
func ConsulSvrReg(client *api.Client, servName string, servTags []string, servInstName string, ...) error
func ConsulWatchKey(client *api.Client, keyName string, stopCh chan struct{}, ...) error
func NewConsulClient(consulIP string) (*api.Client, error)
func PostBaseRequstByConsulDns(interfaceName string, req *base.ProtoRequestS, client *api.Client, ...) (*base.ProtoResponseS, error)
func PostRequstByConsulDns(uin uint64, interfaceName string, realReq interface{}, client *api.Client, ...) (*base.ProtoResponseS, error)
func ReleaseGlobalLock(lock *api.Lock) error
type ConsulServInstS
- func ConsulServDns(client *api.Client, servName string) ([]*ConsulServInstS, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ConsulWatchKeyNotExist = errors.New("Watch Key dos not exist")
	ConsulWatchExit        = errors.New("Watch exit")
)

Functions ¶

func ConsulGlobalLock ¶

func ConsulGlobalLock(client *api.Client, lockName string, watiLockTime string) (*api.Lock, error)

client: consul api对象 lockName: 锁名字 watiLockTime: 得到锁的等待时间，如果超时都没有获得，返回报错 "10s" "100ms"，永久等待就用""

func ConsulGlobalSeq ¶

func ConsulGlobalSeq(client *api.Client, seqName string, initSeqNum int, waitTime string) (int, error)

func ConsulSvrReg ¶

func ConsulSvrReg(client *api.Client, servName string, servTags []string, servInstName string,
	servInstListenIP string, servInstListenPort int, healthCheckUrl string) error

func ConsulWatchKey ¶

func ConsulWatchKey(client *api.Client, keyName string, stopCh chan struct{}, notifyCh chan interface{}) error

对一个key的监控

func NewConsulClient ¶

func NewConsulClient(consulIP string) (*api.Client, error)

func PostBaseRequstByConsulDns ¶

func PostBaseRequstByConsulDns(interfaceName string, req *base.ProtoRequestS, client *api.Client, svrName string) (*base.ProtoResponseS, error)

func PostRequstByConsulDns ¶

func PostRequstByConsulDns(uin uint64, interfaceName string, realReq interface{}, client *api.Client, svrName string) (*base.ProtoResponseS, error)

func ReleaseGlobalLock ¶

func ReleaseGlobalLock(lock *api.Lock) error

Types ¶

type ConsulServInstS ¶

type ConsulServInstS struct {
	ID   string
	IP   string
	Port int
}

func ConsulServDns ¶

func ConsulServDns(client *api.Client, servName string) ([]*ConsulServInstS, error)

通过服务名，获取健康的服务实例列表

Source Files ¶

View all Source files

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