clientproxy

Documentation

Index

• Constants
• Variables
• func Init()
• type EtcdClient
  • func NewEtcdClient(cfg clientv3.Config, options ...EtcdClientOption) (obj *EtcdClient, err error)
  • func (e *EtcdClient) Conn() *clientv3.Client
  • func (e *EtcdClient) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (resp *clientv3.GetResponse, err error)
  • func (e *EtcdClient) Put(ctx context.Context, key, val string, opts ...clientv3.OpOption) (resp *clientv3.PutResponse, err error)
• type EtcdClientOption
  • func WithUniqueZone(zone *view.UniqZone) EtcdClientOption

Constants

const ClientDefaultTimeout = 1

ClientDefaultTimeout ..

Variables

var ClientProxy clientProxy

ClientProxy ..

Functions

func Init

func Init()

Init ...

Types

type EtcdClient

type EtcdClient struct {
	UniqueZone *view.UniqZone
	// contains filtered or unexported fields
}

func NewEtcdClient

func NewEtcdClient(cfg clientv3.Config, options ...EtcdClientOption) (obj *EtcdClient, err error)

NewEtcdClient ..

func (*EtcdClient) Conn

func (e *EtcdClient) Conn() *clientv3.Client

func (*EtcdClient) Get

func (e *EtcdClient) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (resp *clientv3.GetResponse, err error)

func (*EtcdClient) Put

func (e *EtcdClient) Put(ctx context.Context, key, val string, opts ...clientv3.OpOption) (resp *clientv3.PutResponse, err error)

type EtcdClientOption

type EtcdClientOption func(e *EtcdClient)

func WithUniqueZone

func WithUniqueZone(zone *view.UniqZone) EtcdClientOption