kubernetes/vendor/github.com/google/cadvisor/container/containerd/grpc.go

type namespaceInterceptor …

func (ni namespaceInterceptor) unary(ctx context.Context, method string, req, reply interface{ … }

func (ni namespaceInterceptor) stream(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error) { … }

func newNSInterceptors(ns string) (grpc.UnaryClientInterceptor, grpc.StreamClientInterceptor) { … }