From f4c272801a41c36fd246fa59335ac8289e5e5628 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=85=89=E6=98=A5?= Date: Tue, 24 May 2022 16:31:35 +0800 Subject: [PATCH] =?UTF-8?q?-=20=E4=BC=98=E5=8C=96=20etcd?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- etcd_curd.go | 6 ++++++ version.go | 2 +- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/etcd_curd.go b/etcd_curd.go index ffc3af1..426be71 100644 --- a/etcd_curd.go +++ b/etcd_curd.go @@ -3,29 +3,35 @@ package gojobs import ( "context" "go.etcd.io/etcd/client/v3" + "log" ) // Watch 监听 func (e Etcd) Watch(ctx context.Context, key string, opts ...clientv3.OpOption) clientv3.WatchChan { + log.Println("监听:", key) return e.Client.Watch(ctx, key, opts...) } // Create 创建 func (e Etcd) Create(ctx context.Context, key, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error) { + log.Println("创建:", key, val) return e.Client.Put(ctx, key, val, opts...) } // Get 获取 func (e Etcd) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) { + log.Println("获取:", key) return e.Client.Get(ctx, key, opts...) } // Update 更新 func (e Etcd) Update(ctx context.Context, key, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error) { + log.Println("更新:", key, val) return e.Client.Put(ctx, key, val, opts...) } // Delete 删除 func (e Etcd) Delete(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.DeleteResponse, error) { + log.Println("删除:", key) return e.Client.Delete(ctx, key, opts...) } diff --git a/version.go b/version.go index 4d513bf..c4b33b2 100644 --- a/version.go +++ b/version.go @@ -1,3 +1,3 @@ package gojobs -const Version = "1.0.12" +const Version = "1.0.13"