heliosgrpc

package module
v1.51.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 6, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SupportPackageIsVersion3 = realGrpc.SupportPackageIsVersion3
	SupportPackageIsVersion4 = realGrpc.SupportPackageIsVersion4
	SupportPackageIsVersion5 = realGrpc.SupportPackageIsVersion5
	SupportPackageIsVersion6 = realGrpc.SupportPackageIsVersion6
	SupportPackageIsVersion7 = realGrpc.SupportPackageIsVersion7
)
View Source 
const PickFirstBalancerName = realGrpc.PickFirstBalancerName
View Source 
const Version = realGrpc.Version

Variables

View Source 
var DefaultBackoffConfig = realGrpc.DefaultBackoffConfig
View Source 
var EnableTracing = realGrpc.EnableTracing
View Source 
var ErrClientConnClosing = realGrpc.ErrClientConnClosing
View Source 
var ErrClientConnTimeout = realGrpc.ErrClientConnTimeout
View Source 
var ErrServerStopped = realGrpc.ErrServerStopped

Functions

func Code 

func Code(err error) codes.Code

func ErrorDesc 

func ErrorDesc(err error) string

func Errorf 

func Errorf(c codes.Code, format string, a ...interface{}) error

func Invoke 

func Invoke(ctx context.Context, method string, args, reply interface{}, cc *ClientConn, opts ...CallOption) error

func Method 

func Method(ctx context.Context) (string, bool)

func MethodFromServerStream 

func MethodFromServerStream(stream ServerStream) (string, bool)

func NewContextWithServerTransportStream 

func NewContextWithServerTransportStream(ctx context.Context, stream ServerTransportStream) context.Context

func SendHeader 

func SendHeader(ctx context.Context, md metadata.MD) error

func SetHeader 

func SetHeader(ctx context.Context, md metadata.MD) error

func SetTrailer 

func SetTrailer(ctx context.Context, md metadata.MD) error

Types

type BackoffConfig 

type BackoffConfig = realGrpc.BackoffConfig

type CallOption 

type CallOption = realGrpc.CallOption

func CallContentSubtype 

func CallContentSubtype(contentSubtype string) CallOption

func CallCustomCodec 

func CallCustomCodec(codec Codec) CallOption

func FailFast 

func FailFast(failFast bool) CallOption

func ForceCodec 

func ForceCodec(codec encoding.Codec) CallOption
func Header(md *metadata.MD) CallOption

func MaxCallRecvMsgSize 

func MaxCallRecvMsgSize(bytes int) CallOption

func MaxCallSendMsgSize 

func MaxCallSendMsgSize(bytes int) CallOption

func MaxRetryRPCBufferSize 

func MaxRetryRPCBufferSize(bytes int) CallOption

func Peer 

func Peer(p *peer.Peer) CallOption

func PerRPCCredentials 

func PerRPCCredentials(creds credentials.PerRPCCredentials) CallOption

func Trailer 

func Trailer(md *metadata.MD) CallOption

func UseCompressor 

func UseCompressor(name string) CallOption

func WaitForReady 

func WaitForReady(waitForReady bool) CallOption

type ClientConn 

type ClientConn = realGrpc.ClientConn

func Dial 

func Dial(target string, opts ...DialOption) (*ClientConn, error)

func DialContext 

func DialContext(ctx context.Context, target string, opts ...DialOption) (conn *ClientConn, err error)

type ClientConnInterface 

type ClientConnInterface = realGrpc.ClientConnInterface

type ClientStream 

type ClientStream = realGrpc.ClientStream

func NewClientStream 

func NewClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error)

type Codec 

type Codec = realGrpc.Codec

type Compressor 

type Compressor = realGrpc.Compressor

func NewGZIPCompressor 

func NewGZIPCompressor() Compressor

func NewGZIPCompressorWithLevel 

func NewGZIPCompressorWithLevel(level int) (Compressor, error)

type CompressorCallOption 

type CompressorCallOption = realGrpc.CompressorCallOption

type ConnectParams 

type ConnectParams = realGrpc.ConnectParams

type ContentSubtypeCallOption 

type ContentSubtypeCallOption = realGrpc.ContentSubtypeCallOption

type CustomCodecCallOption 

type CustomCodecCallOption = realGrpc.CustomCodecCallOption

type Decompressor 

type Decompressor = realGrpc.Decompressor

func NewGZIPDecompressor 

func NewGZIPDecompressor() Decompressor

type DialOption 

type DialOption = realGrpc.DialOption

func FailOnNonTempDialError 

func FailOnNonTempDialError(f bool) DialOption

func WithAuthority 

func WithAuthority(a string) DialOption

func WithBackoffConfig 

func WithBackoffConfig(b BackoffConfig) DialOption

func WithBackoffMaxDelay 

func WithBackoffMaxDelay(md time.Duration) DialOption

func WithBlock 

func WithBlock() DialOption

func WithChainStreamInterceptor 

func WithChainStreamInterceptor(interceptors ...StreamClientInterceptor) DialOption

func WithChainUnaryInterceptor 

func WithChainUnaryInterceptor(interceptors ...UnaryClientInterceptor) DialOption

func WithChannelzParentID 

func WithChannelzParentID(id *channelz.Identifier) DialOption

func WithCodec 

func WithCodec(c Codec) DialOption

func WithCompressor 

func WithCompressor(cp Compressor) DialOption

func WithConnectParams 

func WithConnectParams(p ConnectParams) DialOption

func WithContextDialer 

func WithContextDialer(f func(context.Context, string) (net.Conn, error)) DialOption

func WithCredentialsBundle 

func WithCredentialsBundle(b credentials.Bundle) DialOption

func WithDecompressor 

func WithDecompressor(dc Decompressor) DialOption

func WithDefaultCallOptions 

func WithDefaultCallOptions(cos ...CallOption) DialOption

func WithDefaultServiceConfig 

func WithDefaultServiceConfig(s string) DialOption

func WithDialer 

func WithDialer(f func(string, time.Duration) (net.Conn, error)) DialOption

func WithDisableHealthCheck 

func WithDisableHealthCheck() DialOption

func WithDisableRetry 

func WithDisableRetry() DialOption

func WithDisableServiceConfig 

func WithDisableServiceConfig() DialOption

func WithInitialConnWindowSize 

func WithInitialConnWindowSize(s int32) DialOption

func WithInitialWindowSize 

func WithInitialWindowSize(s int32) DialOption

func WithInsecure 

func WithInsecure() DialOption

func WithKeepaliveParams 

func WithKeepaliveParams(kp keepalive.ClientParameters) DialOption

func WithMaxHeaderListSize 

func WithMaxHeaderListSize(s uint32) DialOption

func WithMaxMsgSize 

func WithMaxMsgSize(s int) DialOption

func WithNoProxy 

func WithNoProxy() DialOption

func WithPerRPCCredentials 

func WithPerRPCCredentials(creds credentials.PerRPCCredentials) DialOption

func WithReadBufferSize 

func WithReadBufferSize(s int) DialOption

func WithResolvers 

func WithResolvers(rs ...resolver.Builder) DialOption

func WithReturnConnectionError 

func WithReturnConnectionError() DialOption

func WithServiceConfig 

func WithServiceConfig(c <-chan ServiceConfig) DialOption

func WithStatsHandler 

func WithStatsHandler(h stats.Handler) DialOption

func WithStreamInterceptor 

func WithStreamInterceptor(f StreamClientInterceptor) DialOption

func WithTimeout 

func WithTimeout(d time.Duration) DialOption

func WithTransportCredentials 

func WithTransportCredentials(creds credentials.TransportCredentials) DialOption

func WithUnaryInterceptor 

func WithUnaryInterceptor(f UnaryClientInterceptor) DialOption

func WithUserAgent 

func WithUserAgent(s string) DialOption

func WithWriteBufferSize 

func WithWriteBufferSize(s int) DialOption

type EmptyCallOption 

type EmptyCallOption = realGrpc.EmptyCallOption

type EmptyDialOption 

type EmptyDialOption = realGrpc.EmptyDialOption

type EmptyServerOption 

type EmptyServerOption = realGrpc.EmptyServerOption

type FailFastCallOption 

type FailFastCallOption = realGrpc.FailFastCallOption

type ForceCodecCallOption 

type ForceCodecCallOption = realGrpc.ForceCodecCallOption

type HeaderCallOption 

type HeaderCallOption = realGrpc.HeaderCallOption

type MaxRecvMsgSizeCallOption 

type MaxRecvMsgSizeCallOption = realGrpc.MaxRecvMsgSizeCallOption

type MaxRetryRPCBufferSizeCallOption 

type MaxRetryRPCBufferSizeCallOption = realGrpc.MaxRetryRPCBufferSizeCallOption

type MaxSendMsgSizeCallOption 

type MaxSendMsgSizeCallOption = realGrpc.MaxSendMsgSizeCallOption

type MethodConfig 

type MethodConfig = realGrpc.MethodConfig

type MethodDesc 

type MethodDesc = realGrpc.MethodDesc

type MethodInfo 

type MethodInfo = realGrpc.MethodInfo

type PeerCallOption 

type PeerCallOption = realGrpc.PeerCallOption

type PerRPCCredsCallOption 

type PerRPCCredsCallOption = realGrpc.PerRPCCredsCallOption

type PreparedMsg 

type PreparedMsg = realGrpc.PreparedMsg

type Server 

type Server = realGrpc.Server

func NewServer 

func NewServer(opt ...ServerOption) *Server

type ServerOption 

type ServerOption = realGrpc.ServerOption

func ChainStreamInterceptor 

func ChainStreamInterceptor(interceptors ...StreamServerInterceptor) ServerOption

func ChainUnaryInterceptor 

func ChainUnaryInterceptor(interceptors ...UnaryServerInterceptor) ServerOption

func ConnectionTimeout 

func ConnectionTimeout(d time.Duration) ServerOption

func Creds 

func Creds(c credentials.TransportCredentials) ServerOption

func CustomCodec 

func CustomCodec(codec Codec) ServerOption

func ForceServerCodec 

func ForceServerCodec(codec encoding.Codec) ServerOption

func HeaderTableSize 

func HeaderTableSize(s uint32) ServerOption

func InTapHandle 

func InTapHandle(h tap.ServerInHandle) ServerOption

func InitialConnWindowSize 

func InitialConnWindowSize(s int32) ServerOption

func InitialWindowSize 

func InitialWindowSize(s int32) ServerOption

func KeepaliveEnforcementPolicy 

func KeepaliveEnforcementPolicy(kep keepalive.EnforcementPolicy) ServerOption

func KeepaliveParams 

func KeepaliveParams(kp keepalive.ServerParameters) ServerOption

func MaxConcurrentStreams 

func MaxConcurrentStreams(n uint32) ServerOption

func MaxHeaderListSize 

func MaxHeaderListSize(s uint32) ServerOption

func MaxMsgSize 

func MaxMsgSize(m int) ServerOption

func MaxRecvMsgSize 

func MaxRecvMsgSize(m int) ServerOption

func MaxSendMsgSize 

func MaxSendMsgSize(m int) ServerOption

func NumStreamWorkers 

func NumStreamWorkers(numServerWorkers uint32) ServerOption

func RPCCompressor 

func RPCCompressor(cp Compressor) ServerOption

func RPCDecompressor 

func RPCDecompressor(dc Decompressor) ServerOption

func ReadBufferSize 

func ReadBufferSize(s int) ServerOption

func StatsHandler 

func StatsHandler(h stats.Handler) ServerOption

func StreamInterceptor 

func StreamInterceptor(i StreamServerInterceptor) ServerOption

func UnaryInterceptor 

func UnaryInterceptor(i UnaryServerInterceptor) ServerOption

func UnknownServiceHandler 

func UnknownServiceHandler(streamHandler StreamHandler) ServerOption

func WriteBufferSize 

func WriteBufferSize(s int) ServerOption

type ServerStream 

type ServerStream = realGrpc.ServerStream

type ServerTransportStream 

type ServerTransportStream = realGrpc.ServerTransportStream

func ServerTransportStreamFromContext 

func ServerTransportStreamFromContext(ctx context.Context) ServerTransportStream

type ServiceConfig 

type ServiceConfig = realGrpc.ServiceConfig

type ServiceDesc 

type ServiceDesc = realGrpc.ServiceDesc

type ServiceInfo 

type ServiceInfo = realGrpc.ServiceInfo

type ServiceRegistrar 

type ServiceRegistrar = realGrpc.ServiceRegistrar

type Stream 

type Stream = realGrpc.Stream

type StreamClientInterceptor 

type StreamClientInterceptor = realGrpc.StreamClientInterceptor

type StreamDesc 

type StreamDesc = realGrpc.StreamDesc

type StreamHandler 

type StreamHandler = realGrpc.StreamHandler

type StreamServerInfo 

type StreamServerInfo = realGrpc.StreamServerInfo

type StreamServerInterceptor 

type StreamServerInterceptor = realGrpc.StreamServerInterceptor

type Streamer 

type Streamer = realGrpc.Streamer

type TrailerCallOption 

type TrailerCallOption = realGrpc.TrailerCallOption

type UnaryClientInterceptor 

type UnaryClientInterceptor = realGrpc.UnaryClientInterceptor

type UnaryHandler 

type UnaryHandler = realGrpc.UnaryHandler

type UnaryInvoker 

type UnaryInvoker = realGrpc.UnaryInvoker

type UnaryServerInfo 

type UnaryServerInfo = realGrpc.UnaryServerInfo

type UnaryServerInterceptor 

type UnaryServerInterceptor = realGrpc.UnaryServerInterceptor

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.