Versions in this module Expand all Collapse all v0 v0.1.0 May 21, 2022 Changes in this version + var Default = New() + var DefaultOptions = Options + var ErrProxyAllreadySettedClient = errors.New("代理不能重复设置客户端对象") + var ErrProxyNotYetSettedClient = errors.New("代理还未设置客户端对象") + var Logger *log.Log + func UseEtcdOpts(opts ...optparams.Option[clientv3.Config]) optparams.Option[Options] + func WithAutoSyncInterval(iterval int) optparams.Option[clientv3.Config] + func WithDialKeepAliveTime(alivetime int) optparams.Option[clientv3.Config] + func WithDialKeepAliveTimeout(timeout int) optparams.Option[clientv3.Config] + func WithDialTimeout(timeout int) optparams.Option[clientv3.Config] + func WithEtcdConfig(conf *clientv3.Config) optparams.Option[Options] + func WithMaxCallRecvMsgSize(size int) optparams.Option[clientv3.Config] + func WithMaxCallSendMsgSize(size int) optparams.Option[clientv3.Config] + func WithParallelCallback() optparams.Option[Options] + func WithPassword(pwd string) optparams.Option[clientv3.Config] + func WithPermitWithoutStream() optparams.Option[clientv3.Config] + func WithQueryTimeout(timeout int) optparams.Option[Options] + func WithRejectOldCluster() optparams.Option[clientv3.Config] + func WithUsername(username string) optparams.Option[clientv3.Config] + type Callback func(cli *clientv3.Client) error + type EtcdProxy struct + Opt Options + func New() *EtcdProxy + func (proxy *EtcdProxy) Init(endpoints string, opts ...optparams.Option[Options]) error + func (proxy *EtcdProxy) IsOk() bool + func (proxy *EtcdProxy) NewCtx() (ctx context.Context, cancel context.CancelFunc) + func (proxy *EtcdProxy) Regist(cb ...Callback) error + func (proxy *EtcdProxy) SetConnect(cli *clientv3.Client) error + type Options struct + ParallelCallback bool + QueryTimeout time.Duration
Go to main page