grpc

Documentation

Index

• func IsErrCanceled(err error) bool
• func IsErrDeadlineExceeded(err error) bool
• func IsErrUnavailable(err error) bool
• type ClientConn
  • func (config ClientConn) Open(log gopi.Logger) (gopi.Driver, error)
• type ClientPool
  • func (config ClientPool) Open(log gopi.Logger) (gopi.Driver, error)
• type GRPCClientConn
• type GRPCServer
• type Server
  • func (config Server) Open(log gopi.Logger) (gopi.Driver, error)

Functions

func IsErrCanceled

func IsErrCanceled(err error) bool

func IsErrDeadlineExceeded

func IsErrDeadlineExceeded(err error) bool

func IsErrUnavailable

func IsErrUnavailable(err error) bool

Types

type ClientConn

type ClientConn struct {
	Name       string
	Addr       string
	SSL        bool
	SkipVerify bool
	Timeout    time.Duration
}

Client Configuration

func (ClientConn) Open

func (config ClientConn) Open(log gopi.Logger) (gopi.Driver, error)

Open a client

type ClientPool

type ClientPool struct {
	SSL        bool
	SkipVerify bool
	Timeout    time.Duration
	Util       rpc.Util
}

func (ClientPool) Open

func (config ClientPool) Open(log gopi.Logger) (gopi.Driver, error)

type GRPCClientConn

type GRPCClientConn interface {
	gopi.RPCClientConn

	// Return the gRPC ClientConn object
	GRPCConn() *grpc.ClientConn
}

GRPCClientConn is an RPCClientConn which also returns gRPC-specific properties

type GRPCServer

type GRPCServer interface {
	gopi.RPCServer

	// Return the gRPC Server object
	GRPCServer() *grpc.Server
}

GRPCServer interface is an RPCServer which also returns gRPC-specific properties

type Server

type Server struct {
	SSLKey         string
	SSLCertificate string
	Port           uint
	ServerOption   []grpc.ServerOption
	Util           rpc.Util
}

Server is the RPC server configuration

func (Server) Open

func (config Server) Open(log gopi.Logger) (gopi.Driver, error)

Open the server