标签：说明 jobs err cron fmt ec golang putRes etcdclientv3

clientv3.New() 创建连接

config = ec.Config{
　　Endpoints:   []string{"10.0.0.5:2379"},  //连接的etcd集群地址，这里为单机的故一个地址
　　DialTimeout: 30 * time.Second,   //超时时长
}

返回值为clientv3.Client结构体

KV是经常使用的类型，主要用来操作key value值

client.Put() 实际上就是KV接口实现的一个方法

KV.Put 向etcd中插入一个Key，如存在则替换新的值。

if putRes, err = kv.Put(context.TODO(), "/cron/jobs/job3", "test111111 hel3123lo",ec.WithPrevKV()); err != nil {
	fmt.Println(err)
} else {
	fmt.Println("revision: ", putRes.Header.Revision)
	if putRes.PrevKv != nil{
		fmt.Println(string(putRes.PrevKv.Value))
	}
}

WithPrevKV()获取Put事件操作之前的键值对

package main

import (
	"context"
	"fmt"
	"time"

	ec "go.etcd.io/etcd/clientv3"
)

func main() {
	var (
		config ec.Config
		client *ec.Client
		err    error
		kv     ec.KV
		putRes *ec.PutResponse
	)

	config = ec.Config{
		Endpoints:   []string{"10.0.0.5:2379"},
		DialTimeout: 30 * time.Second,
	}

	if client, err = ec.New(config); err != nil {
		fmt.Println(err)
		return
	}

	kv = ec.NewKV(client)

	if putRes, err = kv.Put(context.TODO(), "/cron/jobs/job3", "test111111 hel3123lo",ec.WithPrevKV()); err != nil {
		fmt.Println(err)
	} else {
		fmt.Println("revision: ", putRes.Header.Revision)
		if putRes.PrevKv != nil{
			fmt.Println(string(putRes.PrevKv.Value))
		}
	}

	op:= ec.OpGet("/cron/jobs/job3")
	fmt.Println(string(op.KeyBytes()))
}

 如果Key不存在，则没有事件操作之前的信息

[root@node01 ~]# ETCDCTL_API=3 etcdctl get /cron/jobs/ --prefix
/cron/jobs/job1
test hello
/cron/jobs/job2
test111111 hel3123lo
/cron/jobs/job3
test22222 hello2222
/cron/jobs/job4
test22222 hello2222

标签：说明,jobs,err,cron,fmt,ec,golang,putRes,etcdclientv3
来源： https://www.cnblogs.com/LC161616/p/10380601.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。