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

type Method …

type StreamHandler …

type Stream …

type ServiceDesc …

type serviceSet …

func newServiceSet(interceptor UnaryServerInterceptor) *serviceSet { … }

func (s *serviceSet) register(name string, desc *ServiceDesc) { … }

func (s *serviceSet) unaryCall(ctx context.Context, method Method, info *UnaryServerInfo, data []byte) (p []byte, st *status.Status) { … }

func (s *serviceSet) streamCall(ctx context.Context, stream StreamHandler, info *StreamServerInfo, ss StreamServer) (p []byte, st *status.Status) { … }

func (s *serviceSet) handle(ctx context.Context, req *Request, respond func(*status.Status, []byte, bool, bool) error) (*streamHandler, error) { … }

type streamHandler …

func (s *streamHandler) closeSend() { … }

func (s *streamHandler) data(unmarshal Unmarshaler) error { … }

func (s *streamHandler) SendMsg(m interface{ … }

func (s *streamHandler) RecvMsg(m interface{ … }

func protoUnmarshal(p []byte, obj interface{ … }

func protoMarshal(obj interface{ … }

// convertCode maps stdlib go errors into grpc space.
//
// This is ripped from the grpc-go code base.
func convertCode(err error) codes.Code { … }

func fullPath(service, method string) string { … }

func isNil(resp interface{ … }