Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

heliosgrpc

package module

Go to main page

Versions in this module

v1

v1.51.4

Mar 6, 2023

v1.51.3

Jan 23, 2023

v1.51.2

Jan 4, 2023

v1.51.0

Dec 10, 2022

v1.45.0

Dec 20, 2022

Changes in this version

+ const PickFirstBalancerName

+ const SupportPackageIsVersion3

+ const SupportPackageIsVersion4

+ const SupportPackageIsVersion5

+ const SupportPackageIsVersion6

+ const SupportPackageIsVersion7

+ const Version

+ var DefaultBackoffConfig = realGrpc.DefaultBackoffConfig

+ var EnableTracing = realGrpc.EnableTracing

+ var ErrClientConnClosing = realGrpc.ErrClientConnClosing

+ var ErrClientConnTimeout = realGrpc.ErrClientConnTimeout

+ var ErrServerStopped = realGrpc.ErrServerStopped

+ func Code(err error) codes.Code

+ func ErrorDesc(err error) string

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

+ func Invoke(ctx context.Context, method string, args, reply interface{}, 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 SetTrailer(ctx context.Context, md metadata.MD) error

+ type BackoffConfig = realGrpc.BackoffConfig

+ type CallOption = realGrpc.CallOption

+ func CallContentSubtype(contentSubtype string) CallOption

+ func CallCustomCodec(codec Codec) CallOption

+ func FailFast(failFast bool) CallOption

+ func ForceCodec(codec encoding.Codec) CallOption

+ func Header(md *metadata.MD) CallOption

+ func MaxCallRecvMsgSize(bytes int) CallOption

+ func MaxCallSendMsgSize(bytes int) CallOption

+ func MaxRetryRPCBufferSize(bytes int) CallOption

+ func Peer(p *peer.Peer) CallOption

+ func PerRPCCredentials(creds credentials.PerRPCCredentials) CallOption

+ func Trailer(md *metadata.MD) CallOption

+ func UseCompressor(name string) CallOption

+ func WaitForReady(waitForReady bool) CallOption

+ type ClientConn = realGrpc.ClientConn

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

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

+ type ClientConnInterface = realGrpc.ClientConnInterface

+ type ClientStream = realGrpc.ClientStream

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

+ type Codec = realGrpc.Codec

+ type Compressor = realGrpc.Compressor

+ func NewGZIPCompressor() Compressor

+ func NewGZIPCompressorWithLevel(level int) (Compressor, error)

+ type CompressorCallOption = realGrpc.CompressorCallOption

+ type ConnectParams = realGrpc.ConnectParams

+ type ContentSubtypeCallOption = realGrpc.ContentSubtypeCallOption

+ type CustomCodecCallOption = realGrpc.CustomCodecCallOption

+ type Decompressor = realGrpc.Decompressor

+ func NewGZIPDecompressor() Decompressor

+ type DialOption = realGrpc.DialOption

+ func FailOnNonTempDialError(f bool) DialOption

+ func WithAuthority(a string) DialOption

+ func WithBackoffConfig(b BackoffConfig) DialOption

+ func WithBackoffMaxDelay(md time.Duration) DialOption

+ func WithBlock() DialOption

+ func WithChainStreamInterceptor(interceptors ...StreamClientInterceptor) DialOption

+ func WithChainUnaryInterceptor(interceptors ...UnaryClientInterceptor) DialOption

+ func WithChannelzParentID(id *channelz.Identifier) DialOption

+ func WithCodec(c Codec) DialOption

+ func WithCompressor(cp Compressor) DialOption

+ 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) DialOption

+ func WithDefaultCallOptions(cos ...CallOption) DialOption

+ func WithDefaultServiceConfig(s string) DialOption

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

+ func WithDisableHealthCheck() DialOption

+ func WithDisableRetry() DialOption

+ func WithDisableServiceConfig() DialOption

+ func WithInitialConnWindowSize(s int32) DialOption

+ func WithInitialWindowSize(s int32) DialOption

+ func WithInsecure() DialOption

+ func WithKeepaliveParams(kp keepalive.ClientParameters) DialOption

+ func WithMaxHeaderListSize(s uint32) DialOption

+ func WithMaxMsgSize(s int) DialOption

+ func WithNoProxy() DialOption

+ func WithPerRPCCredentials(creds credentials.PerRPCCredentials) DialOption

+ func WithReadBufferSize(s int) DialOption

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

+ func WithReturnConnectionError() DialOption

+ func WithServiceConfig(c <-chan ServiceConfig) DialOption

+ func WithStatsHandler(h stats.Handler) DialOption

+ func WithStreamInterceptor(f StreamClientInterceptor) DialOption

+ func WithTimeout(d time.Duration) DialOption

+ func WithTransportCredentials(creds credentials.TransportCredentials) DialOption

+ func WithUnaryInterceptor(f UnaryClientInterceptor) DialOption

+ func WithUserAgent(s string) DialOption

+ func WithWriteBufferSize(s int) DialOption

+ type EmptyCallOption = realGrpc.EmptyCallOption

+ type EmptyDialOption = realGrpc.EmptyDialOption

+ type EmptyServerOption = realGrpc.EmptyServerOption

+ type FailFastCallOption = realGrpc.FailFastCallOption

+ type ForceCodecCallOption = realGrpc.ForceCodecCallOption

+ type HeaderCallOption = realGrpc.HeaderCallOption

+ type MaxRecvMsgSizeCallOption = realGrpc.MaxRecvMsgSizeCallOption

+ type MaxRetryRPCBufferSizeCallOption = realGrpc.MaxRetryRPCBufferSizeCallOption

+ type MaxSendMsgSizeCallOption = realGrpc.MaxSendMsgSizeCallOption

+ type MethodConfig = realGrpc.MethodConfig

+ type MethodDesc = realGrpc.MethodDesc

+ type MethodInfo = realGrpc.MethodInfo

+ type PeerCallOption = realGrpc.PeerCallOption

+ type PerRPCCredsCallOption = realGrpc.PerRPCCredsCallOption

+ type PreparedMsg = realGrpc.PreparedMsg

+ type Server = realGrpc.Server

+ func NewServer(opt ...ServerOption) *Server

+ type ServerOption = realGrpc.ServerOption

+ func ChainStreamInterceptor(interceptors ...StreamServerInterceptor) ServerOption

+ func ChainUnaryInterceptor(interceptors ...UnaryServerInterceptor) ServerOption

+ func ConnectionTimeout(d time.Duration) ServerOption

+ func Creds(c credentials.TransportCredentials) ServerOption

+ func CustomCodec(codec Codec) ServerOption

+ func ForceServerCodec(codec encoding.Codec) ServerOption

+ func HeaderTableSize(s uint32) ServerOption

+ func InTapHandle(h tap.ServerInHandle) ServerOption

+ func InitialConnWindowSize(s int32) ServerOption

+ func InitialWindowSize(s int32) ServerOption

+ func KeepaliveEnforcementPolicy(kep keepalive.EnforcementPolicy) ServerOption

+ func KeepaliveParams(kp keepalive.ServerParameters) ServerOption

+ func MaxConcurrentStreams(n uint32) ServerOption

+ func MaxHeaderListSize(s uint32) ServerOption

+ func MaxMsgSize(m int) ServerOption

+ func MaxRecvMsgSize(m int) ServerOption

+ func MaxSendMsgSize(m int) ServerOption

+ func NumStreamWorkers(numServerWorkers uint32) ServerOption

+ func RPCCompressor(cp Compressor) ServerOption

+ func RPCDecompressor(dc Decompressor) ServerOption

+ func ReadBufferSize(s int) ServerOption

+ func StatsHandler(h stats.Handler) ServerOption

+ func StreamInterceptor(i StreamServerInterceptor) ServerOption

+ func UnaryInterceptor(i UnaryServerInterceptor) ServerOption

+ func UnknownServiceHandler(streamHandler StreamHandler) ServerOption

+ func WriteBufferSize(s int) ServerOption

+ type ServerStream = realGrpc.ServerStream

+ type ServerTransportStream = realGrpc.ServerTransportStream

+ func ServerTransportStreamFromContext(ctx context.Context) ServerTransportStream

+ type ServiceConfig = realGrpc.ServiceConfig

+ type ServiceDesc = realGrpc.ServiceDesc

+ type ServiceInfo = realGrpc.ServiceInfo

+ type ServiceRegistrar = realGrpc.ServiceRegistrar

+ type Stream = realGrpc.Stream

+ type StreamClientInterceptor = realGrpc.StreamClientInterceptor

+ type StreamDesc = realGrpc.StreamDesc

+ type StreamHandler = realGrpc.StreamHandler

+ type StreamServerInfo = realGrpc.StreamServerInfo

+ type StreamServerInterceptor = realGrpc.StreamServerInterceptor

+ type Streamer = realGrpc.Streamer

+ type TrailerCallOption = realGrpc.TrailerCallOption

+ type UnaryClientInterceptor = realGrpc.UnaryClientInterceptor

+ type UnaryHandler = realGrpc.UnaryHandler

+ type UnaryInvoker = realGrpc.UnaryInvoker

+ type UnaryServerInfo = realGrpc.UnaryServerInfo

+ type UnaryServerInterceptor = realGrpc.UnaryServerInterceptor