method

pkg/cwplugin/backend.go

@@ -22,6 +22,7 @@ type Backend interface {
 	Flush() error
 	Shutdown() error
 	DeleteAll() error
+	StartAutoCommit() error
 }
 
 type BackendPlugin struct {
@@ -196,6 +197,17 @@ func (b *BackendManager) IsBackendPlugin(plugin string) bool {
 	return false
 }
 
+func (b *BackendManager) StartAutoCommit() error {
+	var err error
+	for _, plugin := range b.backendPlugins {
+		err = plugin.funcs.StartAutoCommit()
+		if err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
 func (b *BackendManager) ReadAT(timeAT time.Time) ([]map[string]string, error) {
 	var ret []map[string]string
 	var err error