grpc

Documentation

Index

• Constants
• 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)

Constants

const (
	DEFAULT_ZONE = "local."
)

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 {
	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
	Zone           string
	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