rpcx

package

Go to main page

Versions in this module

v1

v1.5.21

Apr 26, 2024

v1.5.20

Mar 22, 2024

v1.5.19

May 17, 2023

v1.5.18

Mar 17, 2023

v1.5.17

Feb 13, 2023

v1.5.16

Dec 14, 2022

v1.5.15

Nov 23, 2022

v1.5.14

Aug 29, 2022

v1.5.13

Aug 25, 2022

v1.5.12

Mar 24, 2021

v1.5.11

Mar 24, 2021

v1.5.10

Dec 21, 2020

v1.5.9

Dec 10, 2020

Changes in this version

type GrpcClient

+ ClientConn *grpc.ClientConn

v1.5.8

Nov 26, 2020

v1.5.7

Oct 21, 2020

v1.5.6

Oct 19, 2020

Changes in this version

type GrpcClient

+ func (c *GrpcClient) Close()

type GrpcClientConfig

+ Name []string

type GrpcServer

+ func (s *GrpcServer) Close()

v1.5.5

Sep 21, 2020

Changes in this version

+ type GrpcClient struct

+ Name string

+ func NewGrpcClient(name, addr string, cfg *GrpcClientConfig) (gc *GrpcClient, err error)

+ func (c *GrpcClient) Conn() (conn *grpc.ClientConn, ok bool)

+ type GrpcClientConfig struct

+ BackoffMultiplier string

+ DialOptions []grpc.DialOption

+ InitialBackoff string

+ MaxAttempts string

+ MaxBackoff string

+ MaxTokens string

+ RetryableStatusCodes []string

+ Timeout string

+ TokenRatio string

+ WaitForReady string

+ type GrpcServer struct

+ Name string

+ func NewGrpcServer(name, addr string, cfg *GrpcServerConfig) *GrpcServer

+ func (s *GrpcServer) AddOptions(options ...grpc.ServerOption)

+ func (s *GrpcServer) AddStreamInterceptors(interceptors ...grpc.StreamServerInterceptor)

+ func (s *GrpcServer) AddUnaryInterceptors(interceptors ...grpc.UnaryServerInterceptor)

+ func (s *GrpcServer) RegisterService(register RegisterFn) *GrpcServer

+ func (s *GrpcServer) Start()

+ type GrpcServerConfig struct

+ Timeout int

v1.5.4

Sep 17, 2020

v1.5.3

Sep 15, 2020

v1.5.2

Sep 7, 2020

v1.5.1

Sep 2, 2020

v1.5.0

Aug 25, 2020

v1.4.7

Aug 17, 2020

v1.4.6

Aug 12, 2020

Changes in this version

+ type ClientConfig struct

+ BackoffMultiplier string

+ DialOptions []grpc.DialOption

+ Host string

+ InitialBackoff string

+ MaxAttempts string

+ MaxBackoff string

+ MaxTokens string

+ Name []string

+ RetryableStatusCodes []string

+ Timeout string

+ TokenRatio string

+ WaitForReady string

+ func NewClientConfig(host string, name []string) (*ClientConfig, error)

+ func (clientConfig *ClientConfig) WithDefaultServiceConfig() grpc.DialOption

type DirectClient

+ func NewDirectClientV2(clientConfig *ClientConfig) (*DirectClient, error)

v1.4.5

Aug 11, 2020

v1.4.3

Aug 11, 2020

v1.4.2

Jul 17, 2020

v1.4.1

Jul 16, 2020

v1.4.0

Jun 12, 2020

Changes in this version

+ func WithStreamServerInterceptors(interceptors ...grpc.StreamServerInterceptor) grpc.ServerOption

+ func WithUnaryServerInterceptors(interceptors ...grpc.UnaryServerInterceptor) grpc.ServerOption

+ type RegisterFn func(*grpc.Server)

+ type RpcServer struct

+ func NewRpcServer(listenOn string, timeout int64, register RegisterFn) (*RpcServer, error)

+ func (s *RpcServer) Start()

+ func (s RpcServer) AddOptions(options ...grpc.ServerOption)

+ func (s RpcServer) AddStreamInterceptors(interceptors ...grpc.StreamServerInterceptor)

+ func (s RpcServer) AddUnaryInterceptors(interceptors ...grpc.UnaryServerInterceptor)

+ type Server interface

+ AddOptions func(options ...grpc.ServerOption)

+ AddStreamInterceptors func(interceptors ...grpc.StreamServerInterceptor)

+ AddUnaryInterceptors func(interceptors ...grpc.UnaryServerInterceptor)

+ Start func(register RegisterFn) error

v1.3.9

Jun 8, 2020

v1.3.8

Jun 4, 2020

v1.3.7

Jun 4, 2020

v1.3.6

May 14, 2020

v1.3.5

May 14, 2020

v1.3.4

May 13, 2020

v1.3.3

May 8, 2020

v1.3.2

May 6, 2020

v1.3.1

Apr 28, 2020

v1.3.0

Apr 28, 2020

Changes in this version

+ func WithStreamClientInterceptors(interceptors ...grpc.StreamClientInterceptor) grpc.DialOption

+ func WithUnaryClientInterceptors(interceptors ...grpc.UnaryClientInterceptor) grpc.DialOption

+ type Client interface

+ Next func() (*grpc.ClientConn, bool)

+ type ClientOption func(options *ClientOptions)

+ func WithDialOption(opt grpc.DialOption) ClientOption

+ func WithTimeout(timeout time.Duration) ClientOption

+ type ClientOptions struct

+ DialOptions []grpc.DialOption

+ Timeout time.Duration

+ type DirectClient struct

+ func NewDirectClient(host string, timeout int64, opts ...ClientOption) (*DirectClient, error)

+ func (c *DirectClient) Next() (*grpc.ClientConn, bool)

Other modules containing this package

github.com/sunmi-OS/gocore/v2

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