aboutsummaryrefslogtreecommitdiff
path: root/weed/replication/sub/notifications.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/replication/sub/notifications.go')
-rw-r--r--weed/replication/sub/notifications.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/replication/sub/notifications.go b/weed/replication/sub/notifications.go
index 8a2668f98..d5a910db9 100644
--- a/weed/replication/sub/notifications.go
+++ b/weed/replication/sub/notifications.go
@@ -10,7 +10,7 @@ type NotificationInput interface {
GetName() string
// Initialize initializes the file store
Initialize(configuration util.Configuration, prefix string) error
- ReceiveMessage() (key string, message *filer_pb.EventNotification, err error)
+ ReceiveMessage() (key string, message *filer_pb.EventNotification, onSuccessFn func(), onFailureFn func(), err error)
}
var (