ttrpc

package module

Go to main page

Versions in this module

v1

v1.2.5

Jun 19, 2024

v1.2.4

May 13, 2024

v1.2.3

Feb 5, 2024

Changes in this version

type ClientOpts

+ func WithChainUnaryClientInterceptor(interceptors ...UnaryClientInterceptor) ClientOpts

type ServerOpt

+ func WithChainUnaryServerInterceptor(interceptors ...UnaryServerInterceptor) ServerOpt

v1.2.2

May 9, 2023

v1.2.1

Mar 8, 2023

v1.2.0

Jan 27, 2023

Changes in this version

+ var ErrProtocol = errors.New("protocol error")

+ var ErrStreamClosed = errors.New("ttrpc: stream closed")

+ var File_github_com_containerd_ttrpc_request_proto protoreflect.FileDescriptor

type Client

+ func (c *Client) NewStream(ctx context.Context, desc *StreamDesc, service, method string, req interface{}) (ClientStream, error)

+ type ClientStream interface

+ CloseSend func() error

+ RecvMsg func(m interface{}) error

+ SendMsg func(m interface{}) error

type KeyValue

+ func (*KeyValue) Descriptor() ([]byte, []int)

+ func (x *KeyValue) GetKey() string

+ func (x *KeyValue) GetValue() string

+ func (x *KeyValue) ProtoReflect() protoreflect.Message

type Request

+ func (*Request) Descriptor() ([]byte, []int)

+ func (x *Request) GetMetadata() []*KeyValue

+ func (x *Request) GetMethod() string

+ func (x *Request) GetPayload() []byte

+ func (x *Request) GetService() string

+ func (x *Request) GetTimeoutNano() int64

+ func (x *Request) ProtoReflect() protoreflect.Message

type Response

+ func (*Response) Descriptor() ([]byte, []int)

+ func (x *Response) GetPayload() []byte

+ func (x *Response) GetStatus() *status.Status

+ func (x *Response) ProtoReflect() protoreflect.Message

type Server

+ func (s *Server) RegisterService(name string, desc *ServiceDesc)

type ServiceDesc

+ Streams map[string]Stream

+ type Stream struct

+ Handler StreamHandler

+ StreamingClient bool

+ StreamingServer bool

+ type StreamClientInterceptor func(context.Context)

+ type StreamDesc struct

+ StreamingClient bool

+ StreamingServer bool

+ type StreamHandler func(context.Context, StreamServer) (interface{}, error)

+ type StreamServer interface

+ RecvMsg func(m interface{}) error

+ SendMsg func(m interface{}) error

+ type StreamServerInfo struct

+ FullMethod string

+ StreamingClient bool

+ StreamingServer bool

+ type StreamServerInterceptor func(context.Context, StreamServer, *StreamServerInfo, StreamHandler) (interface{}, error)

type StringList

+ func (*StringList) Descriptor() ([]byte, []int)

+ func (x *StringList) GetList() []string

+ func (x *StringList) ProtoReflect() protoreflect.Message

v1.1.2

May 17, 2023

v1.1.1

Mar 24, 2023

v1.1.0

Nov 8, 2021

v1.0.2

Sep 14, 2020

Changes in this version

type Client

+ func (c *Client) UserOnCloseWait(ctx context.Context) error

v1.0.1

Apr 22, 2020

v1.0.0

Aug 28, 2019

Changes in this version

+ var ErrClosed = errors.New("ttrpc: closed")

+ var ErrServerClosed = errors.New("ttrpc: server closed")

+ func GetMetadataValue(ctx context.Context, name string) (string, bool)

+ func WithMetadata(ctx context.Context, md MD) context.Context

+ type Client struct

+ func NewClient(conn net.Conn, opts ...ClientOpts) *Client

+ func (c *Client) Call(ctx context.Context, service, method string, req, resp interface{}) error

+ func (c *Client) Close() error

+ type ClientOpts func(c *Client)

+ func WithOnClose(onClose func()) ClientOpts

+ func WithUnaryClientInterceptor(i UnaryClientInterceptor) ClientOpts

+ type Handshaker interface

+ Handshake func(ctx context.Context, conn net.Conn) (net.Conn, interface{}, error)

+ type Invoker func(context.Context, *Request, *Response) error

+ type KeyValue struct

+ Key string

+ Value string

+ func (*KeyValue) ProtoMessage()

+ func (m *KeyValue) Reset()

+ func (m *KeyValue) String() string

+ type MD map[string][]string

+ func GetMetadata(ctx context.Context) (MD, bool)

+ func (m MD) Append(key string, values ...string)

+ func (m MD) Get(key string) ([]string, bool)

+ func (m MD) Set(key string, values ...string)

+ type Method func(ctx context.Context, unmarshal func(interface{}) error) (interface{}, error)

+ type Request struct

+ Metadata []*KeyValue

+ Method string

+ Payload []byte

+ Service string

+ TimeoutNano int64

+ func (r *Request) ProtoMessage()

+ func (r *Request) Reset()

+ func (r *Request) String() string

+ type Response struct

+ Payload []byte

+ Status *spb.Status

+ func (r *Response) ProtoMessage()

+ func (r *Response) Reset()

+ func (r *Response) String() string

+ type Server struct

+ func NewServer(opts ...ServerOpt) (*Server, error)

+ func (s *Server) Close() error

+ func (s *Server) Register(name string, methods map[string]Method)

+ func (s *Server) Serve(ctx context.Context, l net.Listener) error

+ func (s *Server) Shutdown(ctx context.Context) error

+ type ServerOpt func(*serverConfig) error

+ func WithServerHandshaker(handshaker Handshaker) ServerOpt

+ func WithUnaryServerInterceptor(i UnaryServerInterceptor) ServerOpt

+ type ServiceDesc struct

+ Methods map[string]Method

+ type StringList struct

+ List []string

+ func (r *StringList) ProtoMessage()

+ func (r *StringList) Reset()

+ func (r *StringList) String() string

+ type UnaryClientInfo struct

+ FullMethod string

+ type UnaryClientInterceptor func(context.Context, *Request, *Response, *UnaryClientInfo, Invoker) error

+ type UnaryServerInfo struct

+ FullMethod string

+ type UnaryServerInterceptor func(context.Context, Unmarshaler, *UnaryServerInfo, Method) (interface{}, error)

+ type UnixCredentialsFunc func(*unix.Ucred) error — linux/amd64

+ func UnixSocketRequireRoot() UnixCredentialsFunc

+ func UnixSocketRequireSameUser() UnixCredentialsFunc

+ func UnixSocketRequireUidGid(uid, gid int) UnixCredentialsFunc

+ func (fn UnixCredentialsFunc) Handshake(ctx context.Context, conn net.Conn) (net.Conn, interface{}, error)

+ type Unmarshaler func(interface{}) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL