kubernetes/vendor/github.com/containerd/ttrpc/interceptor.go

type UnaryServerInfo …

type UnaryClientInfo …

type StreamServerInfo …

type Unmarshaler …

type Invoker …

type UnaryServerInterceptor …

type UnaryClientInterceptor …

func defaultServerInterceptor(ctx context.Context, unmarshal Unmarshaler, _ *UnaryServerInfo, method Method) (interface{ … }

func defaultClientInterceptor(ctx context.Context, req *Request, resp *Response, _ *UnaryClientInfo, invoker Invoker) error { … }

type StreamServerInterceptor …

func defaultStreamServerInterceptor(ctx context.Context, ss StreamServer, _ *StreamServerInfo, stream StreamHandler) (interface{ … }

type StreamClientInterceptor …