From be343fe5b36043638d08320bd0d03ea2cb70894d Mon Sep 17 00:00:00 2001 From: Nathaniel Cook Date: Thu, 13 Apr 2017 16:21:07 -0600 Subject: [PATCH] fix snaphost typo in UDF agent code --- udf/agent/agent.go | 4 ++-- udf/agent/examples/mirror/mirror.go | 2 +- udf/agent/examples/moving_avg/moving_avg.go | 2 +- udf/agent/examples/outliers/outliers.go | 2 +- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/udf/agent/agent.go b/udf/agent/agent.go index 21d720329..449ae365c 100644 --- a/udf/agent/agent.go +++ b/udf/agent/agent.go @@ -25,7 +25,7 @@ type Handler interface { // Initialize the Handler with the provided options. Init(*udf.InitRequest) (*udf.InitResponse, error) // Create a snapshot of the running state of the handler. - Snaphost() (*udf.SnapshotResponse, error) + Snapshot() (*udf.SnapshotResponse, error) // Restore a previous snapshot. Restore(*udf.RestoreRequest) (*udf.RestoreResponse, error) @@ -180,7 +180,7 @@ func (a *Agent) readLoop() error { }, } case *udf.Request_Snapshot: - snapshot, err := a.Handler.Snaphost() + snapshot, err := a.Handler.Snapshot() if err != nil { return err } diff --git a/udf/agent/examples/mirror/mirror.go b/udf/agent/examples/mirror/mirror.go index 02c71a7bb..b01d51471 100644 --- a/udf/agent/examples/mirror/mirror.go +++ b/udf/agent/examples/mirror/mirror.go @@ -41,7 +41,7 @@ func (*mirrorHandler) Init(r *udf.InitRequest) (*udf.InitResponse, error) { } // Create a snapshot of the running state of the process. -func (*mirrorHandler) Snaphost() (*udf.SnapshotResponse, error) { +func (*mirrorHandler) Snapshot() (*udf.SnapshotResponse, error) { return &udf.SnapshotResponse{}, nil } diff --git a/udf/agent/examples/moving_avg/moving_avg.go b/udf/agent/examples/moving_avg/moving_avg.go index 0f48a35e0..2f8689c9d 100644 --- a/udf/agent/examples/moving_avg/moving_avg.go +++ b/udf/agent/examples/moving_avg/moving_avg.go @@ -97,7 +97,7 @@ func (a *avgHandler) Init(r *udf.InitRequest) (*udf.InitResponse, error) { } // Create a snapshot of the running state of the process. -func (a *avgHandler) Snaphost() (*udf.SnapshotResponse, error) { +func (a *avgHandler) Snapshot() (*udf.SnapshotResponse, error) { var buf bytes.Buffer enc := gob.NewEncoder(&buf) enc.Encode(a.state) diff --git a/udf/agent/examples/outliers/outliers.go b/udf/agent/examples/outliers/outliers.go index 7f91312f4..a4b32b91b 100644 --- a/udf/agent/examples/outliers/outliers.go +++ b/udf/agent/examples/outliers/outliers.go @@ -64,7 +64,7 @@ func (o *outlierHandler) Init(r *udf.InitRequest) (*udf.InitResponse, error) { } // Create a snapshot of the running state of the process. -func (o *outlierHandler) Snaphost() (*udf.SnapshotResponse, error) { +func (o *outlierHandler) Snapshot() (*udf.SnapshotResponse, error) { return &udf.SnapshotResponse{}, nil }