Documentation
¶
Overview ¶
Package grpc implements an RPC system called gRPC.
See grpc.io for more information about gRPC.
Index ¶
- Constants
- Variables
- func ClientSupportedCompressors(ctx context.Context) ([]string, error)
- func Code(err error) codes.Codedeprecated
- func ErrorDesc(err error) stringdeprecated
- func Errorf(c codes.Code, format string, a ...any) errordeprecated
- func Invoke(ctx context.Context, method string, args, reply any, cc *ClientConn, ...) error
- func Method(ctx context.Context) (string, bool)
- func MethodFromServerStream(stream ServerStream) (string, bool)
- func NewContextWithServerTransportStream(ctx context.Context, stream ServerTransportStream) context.Context
- func SendHeader(ctx context.Context, md metadata.MD) error
- func SetHeader(ctx context.Context, md metadata.MD) error
- func SetSendCompressor(ctx context.Context, name string) error
- func SetTrailer(ctx context.Context, md metadata.MD) error
- type AuthorityOverrideCallOption
- type BackoffConfigdeprecated
- type BidiStreamingClient
- type BidiStreamingServer
- type CallOption
- func CallAuthority(authority string) CallOption
- func CallContentSubtype(contentSubtype string) CallOption
- func CallCustomCodec(codec Codec) CallOptiondeprecated
- func FailFast(failFast bool) CallOptiondeprecated
- func ForceCodec(codec encoding.Codec) CallOption
- func ForceCodecV2(codec encoding.CodecV2) CallOption
- func Header(md *metadata.MD) CallOption
- func MaxCallRecvMsgSize(bytes int) CallOption
- func MaxCallSendMsgSize(bytes int) CallOption
- func MaxRetryRPCBufferSize(bytes int) CallOption
- func OnFinish(onFinish func(err error)) CallOption
- func Peer(p *peer.Peer) CallOption
- func PerRPCCredentials(creds credentials.PerRPCCredentials) CallOption
- func StaticMethod() CallOption
- func Trailer(md *metadata.MD) CallOption
- func UseCompressor(name string) CallOption
- func WaitForReady(waitForReady bool) CallOption
- type ClientConn
- func (cc *ClientConn) CanonicalTarget() string
- func (cc *ClientConn) Close() error
- func (cc *ClientConn) Connect()
- func (cc *ClientConn) GetMethodConfig(method string) MethodConfig
- func (cc *ClientConn) GetState() connectivity.State
- func (cc *ClientConn) Invoke(ctx context.Context, method string, args, reply any, opts ...CallOption) error
- func (cc *ClientConn) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error)
- func (cc *ClientConn) ResetConnectBackoff()
- func (cc *ClientConn) Target() string
- func (cc *ClientConn) WaitForStateChange(ctx context.Context, sourceState connectivity.State) bool
- type ClientConnInterface
- type ClientStream
- type ClientStreamingClient
- type ClientStreamingServer
- type Codecdeprecated
- type Compressordeprecated
- type CompressorCallOption
- type ConnectParams
- type ContentSubtypeCallOption
- type CustomCodecCallOption
- type Decompressordeprecated
- func NewGZIPDecompressor() Decompressordeprecated
- type DialOption
- func FailOnNonTempDialError(f bool) DialOptiondeprecated
- func WithAuthority(a string) DialOption
- func WithBackoffConfig(b BackoffConfig) DialOptiondeprecated
- func WithBackoffMaxDelay(md time.Duration) DialOptiondeprecated
- func WithBlock() DialOptiondeprecated
- func WithChainStreamInterceptor(interceptors ...StreamClientInterceptor) DialOption
- func WithChainUnaryInterceptor(interceptors ...UnaryClientInterceptor) DialOption
- func WithChannelzParentID(c channelz.Identifier) DialOption
- func WithCodec(c Codec) DialOptiondeprecated
- func WithCompressor(cp Compressor) DialOptiondeprecated
- func WithConnectParams(p ConnectParams) DialOption
- func WithContextDialer(f func(context.Context, string) (net.Conn, error)) DialOption
- func WithCredentialsBundle(b credentials.Bundle) DialOption
- func WithDecompressor(dc Decompressor) DialOptiondeprecated
- func WithDefaultCallOptions(cos ...CallOption) DialOption
- func WithDefaultServiceConfig(s string) DialOption
- func WithDialer(f func(string, time.Duration) (net.Conn, error)) DialOptiondeprecated
- func WithDisableHealthCheck() DialOption
- func WithDisableRetry() DialOption
- func WithDisableServiceConfig() DialOption
- func WithIdleTimeout(d time.Duration) DialOption
- func WithInitialConnWindowSize(s int32) DialOption
- func WithInitialWindowSize(s int32) DialOption
- func WithInsecure() DialOptiondeprecated
- func WithKeepaliveParams(kp keepalive.ClientParameters) DialOption
- func WithLocalDNSResolution() DialOption
- func WithMaxCallAttempts(n int) DialOption
- func WithMaxHeaderListSize(s uint32) DialOption
- func WithMaxMsgSize(s int) DialOptiondeprecated
- func WithNoProxy() DialOption
- func WithPerRPCCredentials(creds credentials.PerRPCCredentials) DialOption
- func WithReadBufferSize(s int) DialOption