From d9edc898a8d4a5d98cbf056cf297517f0c484715 Mon Sep 17 00:00:00 2001 From: amyangfei Date: Wed, 9 Sep 2020 12:08:07 +0800 Subject: [PATCH] fix make check --- cdc/server.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/cdc/server.go b/cdc/server.go index 34f42c34c82..662c7148a61 100644 --- a/cdc/server.go +++ b/cdc/server.go @@ -136,12 +136,14 @@ func Timezone(tz *time.Location) ServerOption { } } +// OwnerFlushInterval returns a ServerOption that sets the ownerFlushInterval func OwnerFlushInterval(dur time.Duration) ServerOption { return func(o *options) { o.ownerFlushInterval = dur } } +// ProcessorFlushInterval returns a ServerOption that sets the processorFlushInterval func ProcessorFlushInterval(dur time.Duration) ServerOption { return func(o *options) { o.processorFlushInterval = dur