grpc

Documentation

Index

• func IsErrCanceled(err error) bool
• func IsErrDeadlineExceeded(err error) bool
• func IsErrUnavailable(err error) bool
• func NewEvent(source_ gopi.Unit, type_ gopi.RPCEventType) gopi.RPCEvent
• func ParseIP(addr string) (gopi.RPCServiceRecord, error)
• func SelectAddr(service gopi.RPCServiceRecord, flag gopi.RPCFlag) []net.IP
• type ClientConn
  • func (ClientConn) Name() string
  • func (config ClientConn) New(log gopi.Logger) (gopi.Unit, error)
• type ClientPool
  • func (ClientPool) Name() string
  • func (config ClientPool) New(log gopi.Logger) (gopi.Unit, error)
• type GRPCClientConn
• type GRPCServer
• type Server
  • func (Server) Name() string
  • func (config Server) New(log gopi.Logger) (gopi.Unit, error)

Functions

func IsErrCanceled

func IsErrCanceled(err error) bool

func IsErrDeadlineExceeded

func IsErrDeadlineExceeded(err error) bool

func IsErrUnavailable

func IsErrUnavailable(err error) bool

func NewEvent

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

func ParseIP

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

ParseIP turns

func SelectAddr

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

Convert RPCServiceRecord into a set of addresses

Types

type ClientConn

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

func (ClientConn) Name

func (ClientConn) Name() string

func (ClientConn) New

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

type ClientPool

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

func (ClientPool) Name

func (ClientPool) Name() string

func (ClientPool) New

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

type GRPCClientConn

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)