xjf_etcd

Documentation

Index

• type EtcdValue
• type XjfEtcd
  • func NewXjfEtcd(endPoints []string) *XjfEtcd
  • func (c *XjfEtcd) DiscoverServer(ctx context.Context, key string) error
  • func (c *XjfEtcd) GrpcCall(ctx context.Context, key string) (*grpc.ClientConn, error)
  • func (c *XjfEtcd) HttpCall(ctx context.Context, key string) (*http.Client, error)
  • func (c *XjfEtcd) RegisterKeepAlive(ctx context.Context, key string, value string, id clientv3.LeaseID) error
  • func (c *XjfEtcd) RegisterServer(ctx context.Context, key string, value *EtcdValue) error
  • func (c *XjfEtcd) WatchServer(ctx context.Context, key string)

Types

type EtcdValue

type EtcdValue struct {
	Ip   string `json:"ip" bson:"ip"`
	Http string `json:"http" bson:"http"`
	Grpc string `json:"grpc" bson:"grpc"`
}

type XjfEtcd

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

func NewXjfEtcd

func NewXjfEtcd(endPoints []string) *XjfEtcd

func (*XjfEtcd) DiscoverServer

func (c *XjfEtcd) DiscoverServer(ctx context.Context, key string) error

func (*XjfEtcd) GrpcCall

func (c *XjfEtcd) GrpcCall(ctx context.Context, key string) (*grpc.ClientConn, error)

func (*XjfEtcd) HttpCall

func (c *XjfEtcd) HttpCall(ctx context.Context, key string) (*http.Client, error)

func (*XjfEtcd) RegisterKeepAlive

func (c *XjfEtcd) RegisterKeepAlive(ctx context.Context, key string, value string, id clientv3.LeaseID) error

func (*XjfEtcd) RegisterServer

func (c *XjfEtcd) RegisterServer(ctx context.Context, key string, value *EtcdValue) error

func (*XjfEtcd) WatchServer

func (c *XjfEtcd) WatchServer(ctx context.Context, key string)