|
|
@@ -15,7 +15,6 @@
|
|
|
package v3rpc
|
|
|
|
|
|
import (
|
|
|
- "strings"
|
|
|
"sync"
|
|
|
"time"
|
|
|
|
|
|
@@ -95,14 +94,6 @@ func newStreamInterceptor(s *etcdserver.EtcdServer) grpc.StreamServerInterceptor
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-func splitMethodName(fullMethodName string) (string, string) {
|
|
|
- fullMethodName = strings.TrimPrefix(fullMethodName, "/") // remove leading slash
|
|
|
- if i := strings.Index(fullMethodName, "/"); i >= 0 {
|
|
|
- return fullMethodName[:i], fullMethodName[i+1:]
|
|
|
- }
|
|
|
- return "unknown", "unknown"
|
|
|
-}
|
|
|
-
|
|
|
type serverStreamWithCtx struct {
|
|
|
grpc.ServerStream
|
|
|
ctx context.Context
|