TBR veyron2/vom: Rename NewBinaryEncoder to NewEncoder
MultiPart: 1/3
Change-Id: I713885b39e45036c18a722ce9bc38c6f6e7c6fc7
diff --git a/runtimes/google/ipc/client.go b/runtimes/google/ipc/client.go
index 5e0815e..f38c589 100644
--- a/runtimes/google/ipc/client.go
+++ b/runtimes/google/ipc/client.go
@@ -744,7 +744,7 @@
dc: dc,
}
var err error
- if fc.enc, err = vom.NewBinaryEncoder(flow); err != nil {
+ if fc.enc, err = vom.NewEncoder(flow); err != nil {
berr := verror.New(verror.ErrBadProtocol, fc.ctx, verror.New(errVomEncoder, fc.ctx, err))
return nil, fc.close(berr)
}
diff --git a/runtimes/google/ipc/server.go b/runtimes/google/ipc/server.go
index 6e3e628..f7c252b 100644
--- a/runtimes/google/ipc/server.go
+++ b/runtimes/google/ipc/server.go
@@ -945,7 +945,7 @@
flow.Close()
return nil, err
}
- if fs.enc, err = vom.NewBinaryEncoder(flow); err != nil {
+ if fs.enc, err = vom.NewEncoder(flow); err != nil {
flow.Close()
return nil, err
}
diff --git a/runtimes/google/ipc/stream/manager/listener.go b/runtimes/google/ipc/stream/manager/listener.go
index e018d04..9dbb227 100644
--- a/runtimes/google/ipc/stream/manager/listener.go
+++ b/runtimes/google/ipc/stream/manager/listener.go
@@ -188,7 +188,7 @@
}
var request proxy.Request
var response proxy.Response
- enc, err := vom.NewBinaryEncoder(flow)
+ enc, err := vom.NewEncoder(flow)
if err != nil {
flow.Close()
vf.StopAccepting()
diff --git a/runtimes/google/ipc/stream/proxy/proxy.go b/runtimes/google/ipc/stream/proxy/proxy.go
index f0e7d7c..5c2f9c7 100644
--- a/runtimes/google/ipc/stream/proxy/proxy.go
+++ b/runtimes/google/ipc/stream/proxy/proxy.go
@@ -244,7 +244,7 @@
response.Endpoint = ep.String()
}
}
- enc, err := vom.NewBinaryEncoder(conn)
+ enc, err := vom.NewEncoder(conn)
if err != nil {
proxyLog().Infof("Failed to create Encoder for server %v: %v", server, err)
server.Close(err)
diff --git a/runtimes/google/ipc/stream/vc/auth.go b/runtimes/google/ipc/stream/vc/auth.go
index 64c4ceb..5cb4b4f 100644
--- a/runtimes/google/ipc/stream/vc/auth.go
+++ b/runtimes/google/ipc/stream/vc/auth.go
@@ -94,7 +94,7 @@
return err
}
var buf bytes.Buffer
- enc, err := vom.NewBinaryEncoder(&buf)
+ enc, err := vom.NewEncoder(&buf)
if err != nil {
return err
}
@@ -114,7 +114,7 @@
return err
}
defer msg.Release()
- enc, err = vom.NewBinaryEncoder(w)
+ enc, err = vom.NewEncoder(w)
if err != nil {
return err
}
diff --git a/security/serialization/signing_writer.go b/security/serialization/signing_writer.go
index 0eeeee0..ea9ce43 100644
--- a/security/serialization/signing_writer.go
+++ b/security/serialization/signing_writer.go
@@ -88,7 +88,7 @@
if (data == nil) || (signature == nil) || (s == nil) {
return nil, fmt.Errorf("data:%v signature:%v signer:%v cannot be nil", data, signature, s)
}
- enc, err := vom.NewBinaryEncoder(signature)
+ enc, err := vom.NewEncoder(signature)
if err != nil {
return nil, fmt.Errorf("failed to create new encoder: %v", err)
}
diff --git a/security/storage.go b/security/storage.go
index 7afc1f2..308b238 100644
--- a/security/storage.go
+++ b/security/storage.go
@@ -17,7 +17,7 @@
if err != nil {
return err
}
- enc, err := vom.NewBinaryEncoder(swc)
+ enc, err := vom.NewEncoder(swc)
if err != nil {
swc.Close()
return err
diff --git a/tools/principal/main.go b/tools/principal/main.go
index 666b4aa..43fdb3d 100644
--- a/tools/principal/main.go
+++ b/tools/principal/main.go
@@ -807,7 +807,7 @@
func base64VomEncode(i interface{}) (string, error) {
buf := &bytes.Buffer{}
closer := base64.NewEncoder(base64.URLEncoding, buf)
- enc, err := vom.NewBinaryEncoder(closer)
+ enc, err := vom.NewEncoder(closer)
if err != nil {
return "", err
}