diff --git a/cmd/config_job_source.go b/cmd/config_job_source.go index fb1dccb..257e8ee 100644 --- a/cmd/config_job_source.go +++ b/cmd/config_job_source.go @@ -104,7 +104,6 @@ outer: handler := Handler{ Logger: log, PullACL: j.Datasets, - // TODO should set SinkMapping here? no, but check Handler impl } // handle connection diff --git a/cmd/handler.go b/cmd/handler.go index ce1179d..3189257 100644 --- a/cmd/handler.go +++ b/cmd/handler.go @@ -32,9 +32,8 @@ type IncrementalTransferRequest struct { } type Handler struct { - Logger Logger - PullACL zfs.DatasetFilter - SinkMappingFunc func(clientIdentity string) (mapping DatasetMapping, err error) + Logger Logger + PullACL zfs.DatasetFilter } func registerEndpoints(server rpc.RPCServer, handler Handler) (err error) {