sigrpc

Documentation

Index

• func OptionWithX509KeyPair(certPemFile, certKeyFile string) (grpc.ServerOption, error)
• 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 WithKeepAliveParams(keepAliveTime, keepAliveTimeout time.Duration, permitWithoutStream bool) grpc.DialOption
• func WithTLSConfigTransportCreds(c *tls.Config) grpc.DialOption
• 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 OptionWithX509KeyPair

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

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 WithKeepAliveParams

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

func WithTLSConfigTransportCreds

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

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