sigrpc

Documentation

Index

• func TcpListener(addr string) (net.Listener, error)
• func TransportCredentialsOption(certPemFile string, serverNameOverride string) (grpc.DialOption, error)
• func WithDefaultDialBlock() grpc.DialOption
• func WithDefaultKeepAlive() grpc.ServerOption
• func WithDefaultKeepAliveEnforcement() grpc.ServerOption
• func WithDefaultKeepAliveParams() grpc.DialOption
• func WithDefaultServiceConfig(defaultServiceConfig string) grpc.DialOption
• func WithDialBlock(dialBlock bool) grpc.DialOption
• func WithInsecureTransportCreds() grpc.DialOption
• func WithKeepAlive(maxConnIdle, maxConnAge, maxConnAgeGrace time.Duration, ...) grpc.ServerOption
• func WithKeepAliveEnforcement(enabled bool, minTime time.Duration, permitWithoutStream bool) grpc.ServerOption
• func WithKeepAliveParams(keepAliveTime, keepAliveTimeout time.Duration, permitWithoutStream bool) grpc.DialOption
• func WithTLSConfigTransportCreds(c *tls.Config) grpc.DialOption
• func WithX509KeyPair(certPemFile, certKeyFile string) (grpc.ServerOption, error)
• type Client
  • func NewClient(address string, opts ...grpc.DialOption) (*Client, error)
  • func NewClientWithDialTimeout(address string, dialTimeout time.Duration, opts ...grpc.DialOption) (*Client, error)
• type Server
  • func NewServer(listener net.Listener, opts ...grpc.ServerOption) (*Server, error)
  • func (s *Server) Close() error
  • func (s *Server) Start() error
  • func (s *Server) Stop() error

Functions

func TcpListener

func TcpListener(addr string) (net.Listener, error)

func TransportCredentialsOption

func TransportCredentialsOption(certPemFile string, serverNameOverride string) (grpc.DialOption, error)

func WithDefaultDialBlock

func WithDefaultDialBlock() grpc.DialOption

func WithDefaultKeepAlive

func WithDefaultKeepAlive() grpc.ServerOption

func WithDefaultKeepAliveEnforcement

func WithDefaultKeepAliveEnforcement() grpc.ServerOption

func WithDefaultKeepAliveParams

func WithDefaultKeepAliveParams() grpc.DialOption

func WithDefaultServiceConfig

func WithDefaultServiceConfig(defaultServiceConfig string) grpc.DialOption

func WithDialBlock

func WithDialBlock(dialBlock bool) grpc.DialOption

func WithInsecureTransportCreds

func WithInsecureTransportCreds() grpc.DialOption

func WithKeepAlive

func WithKeepAlive(maxConnIdle, maxConnAge, maxConnAgeGrace time.Duration, keepAliveTime, pingTimeout time.Duration) grpc.ServerOption

func WithKeepAliveEnforcement

func WithKeepAliveEnforcement(enabled bool, minTime time.Duration, permitWithoutStream bool) grpc.ServerOption

func WithKeepAliveParams

func WithKeepAliveParams(keepAliveTime, keepAliveTimeout time.Duration, permitWithoutStream bool) grpc.DialOption

func WithTLSConfigTransportCreds

func WithTLSConfigTransportCreds(c *tls.Config) grpc.DialOption

func WithX509KeyPair

func WithX509KeyPair(certPemFile, certKeyFile string) (grpc.ServerOption, error)

Types

type Client

type Client struct {
	*grpc.ClientConn
}

func NewClient

func NewClient(address string, opts ...grpc.DialOption) (*Client, error)

func NewClientWithDialTimeout

func NewClientWithDialTimeout(address string, dialTimeout time.Duration, opts ...grpc.DialOption) (*Client, error)

type Server

type Server struct {
	*grpc.Server
	// contains filtered or unexported fields
}

func NewServer

func NewServer(listener net.Listener, opts ...grpc.ServerOption) (*Server, error)

func (*Server) Close

func (s *Server) Close() error

func (*Server) Start

func (s *Server) Start() error

func (*Server) Stop

func (s *Server) Stop() error