grpc

package
v2.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 26, 2020 License: BSD-2-Clause Imports: 18 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func IsErrCanceled

func IsErrCanceled(err error) bool

func IsErrDeadlineExceeded

func IsErrDeadlineExceeded(err error) bool

func IsErrUnavailable

func IsErrUnavailable(err error) bool

func NewEvent added in v2.0.2

func NewEvent(source_ gopi.Unit, type_ gopi.RPCEventType) gopi.RPCEvent

func ParseIP added in v2.0.2

func ParseIP(addr string) (gopi.RPCServiceRecord, error)

ParseIP turns

func SelectAddr added in v2.0.2

func SelectAddr(service gopi.RPCServiceRecord, flag gopi.RPCFlag) []net.IP

Convert RPCServiceRecord into a set of addresses

Types

type ClientConn added in v2.0.2

type ClientConn struct {
	Fifo       string
	Addr       net.IP
	Port       uint16
	Flags      gopi.RPCFlag
	SSL        bool
	SkipVerify bool
	Timeout    time.Duration
}

func (ClientConn) Name added in v2.0.2

func (ClientConn) Name() string

func (ClientConn) New added in v2.0.2

func (config ClientConn) New(log gopi.Logger) (gopi.Unit, error)

type ClientPool added in v2.0.2

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

func (ClientPool) Name added in v2.0.2

func (ClientPool) Name() string

func (ClientPool) New added in v2.0.2

func (config ClientPool) New(log gopi.Logger) (gopi.Unit, error)

type GRPCClientConn added in v2.0.2

type GRPCClientConn interface {
	gopi.RPCClientConn

	// Return the gRPC Server object
	GRPCClient() grpc.ClientConnInterface
}

GRPCClientConn interface 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
	File           string
	FileGroup      string
	ServerOption   []grpc.ServerOption
	Bus            gopi.Bus
}

func (Server) Name

func (Server) Name() string

func (Server) New

func (config Server) New(log gopi.Logger) (gopi.Unit, error)

Jump to

Keyboard shortcuts

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