consul

package

v0.0.0-...-6a0a93c Latest Latest Go to latest Published: Jul 15, 2025 License: MIT Imports: 8 Imported by: 0

Details

pkg/discovery/consul_discovery.go

This section is empty.

This section is empty.

This section is empty.

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

func NewConsulClient(addr string) (*ConsulClient, error)

func (c *ConsulClient) DeregisterService(id string) error

func (c *ConsulClient) GetKV(key string) ([]byte, error)

GetKV 从 Consul KV 读取数据

func (c *ConsulClient) PutKV(key string, value []byte) error

PutKV 将数据写入 Consul KV，key 如 config/app.yaml

func (c *ConsulClient) RegisterService(id, name, address string, port int, tags []string) error

func (c *ConsulClient) WatchKey(ctx context.Context, key string, waitIndex uint64) ([]byte, uint64, error)

Example: Watch KV key changes (simple blocking query)

type Discovery interface {
	// GetGRPCConn 获取指定服务的 gRPC 连接
	GetGRPCConn(serviceName string) (*grpc.ClientConn, error)
}

func NewConsulDiscovery(addr string) (Discovery, error)

type ServiceRegistration struct {
	ID      string
	Name    string
	Address string
	Port    int
	Client  *api.Client
}