ngrpc

package module

v0.0.21 Latest Latest Go to latest Published: Aug 30, 2022 License: MIT Imports: 12 Imported by: 4

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/smartwalle/ngrpc

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func WithInsecure() grpc.DialOption
type ClientConn
- func Dial(target string, opts ...grpc.DialOption) *ClientConn
- func (this *ClientConn) Close()
- func (this *ClientConn) Invoke(ctx context.Context, method string, args, reply interface{}, ...) error
- func (this *ClientConn) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
- func (this *ClientConn) Prepare()
type ClientPool
- func NewClientPool(size int32, fn DialFun) *ClientPool
- func (this *ClientPool) Close()
- func (this *ClientPool) Get() (*grpc.ClientConn, error)
- func (this *ClientPool) Prepare()
type DialFun
type DialOption
- func WithPoolSize(size int32) DialOption
- func WithTimeout(timeout time.Duration) DialOption
type Header
- func HeaderFromIncoming(ctx context.Context) *Header
- func HeaderFromMetadata(md metadata.MD) *Header
- func HeaderFromOutgoing(ctx context.Context) *Header
- func NewHeader() *Header
- func (this *Header) Context(ctx context.Context) context.Context
- func (this *Header) Del(key string)
- func (this *Header) ForeachKey(handler func(key, val string) error) error
- func (this *Header) Get(key string) string
- func (this *Header) Len() int
- func (this *Header) Raw() metadata.MD
- func (this *Header) Set(key, value string)
type Registry
type Server
- func NewServer(domain, service, node string, registry Registry, opts ...grpc.ServerOption) (*Server, error)
- func (this *Server) Addr() string
- func (this *Server) Domain() string
- func (this *Server) GracefulStop()
- func (this *Server) Name() string
- func (this *Server) Node() string
- func (this *Server) RegisterService(desc *grpc.ServiceDesc, impl interface{})
- func (this *Server) Registry() Registry
- func (this *Server) Run() error
- func (this *Server) Server() *grpc.Server
- func (this *Server) Service() string
- func (this *Server) Stop()
type ServerOption
- func WithAddress(addr string) ServerOption
- func WithRegisterTTL(ttl int64) ServerOption

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrServerNotFound = errors.New("server not found")
)

Functions ¶

func WithInsecure ¶ added in v0.0.20

func WithInsecure() grpc.DialOption

Types ¶

type ClientConn ¶

type ClientConn struct {
	// contains filtered or unexported fields
}

func Dial ¶

func Dial(target string, opts ...grpc.DialOption) *ClientConn

func (*ClientConn) Close ¶

func (this *ClientConn) Close()

func (*ClientConn) Invoke ¶

func (this *ClientConn) Invoke(ctx context.Context, method string, args, reply interface{}, opts ...grpc.CallOption) error

func (*ClientConn) NewStream ¶

func (this *ClientConn) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)

func (*ClientConn) Prepare ¶

func (this *ClientConn) Prepare()

type ClientPool ¶

type ClientPool struct {
	// contains filtered or unexported fields
}

func NewClientPool ¶

func NewClientPool(size int32, fn DialFun) *ClientPool

func (*ClientPool) Close ¶

func (this *ClientPool) Close()

func (*ClientPool) Get ¶

func (this *ClientPool) Get() (*grpc.ClientConn, error)

func (*ClientPool) Prepare ¶

func (this *ClientPool) Prepare()

type DialFun ¶

type DialFun func() (*grpc.ClientConn, error)

type DialOption ¶

type DialOption struct {
	grpc.EmptyDialOption
	// contains filtered or unexported fields
}

func WithPoolSize ¶

func WithPoolSize(size int32) DialOption

func WithTimeout ¶

func WithTimeout(timeout time.Duration) DialOption

type Header ¶

type Header struct {
	// contains filtered or unexported fields
}

func HeaderFromIncoming ¶

func HeaderFromIncoming(ctx context.Context) *Header

func HeaderFromMetadata ¶

func HeaderFromMetadata(md metadata.MD) *Header

func HeaderFromOutgoing ¶

func HeaderFromOutgoing(ctx context.Context) *Header

func NewHeader ¶

func NewHeader() *Header

func (*Header) Context ¶

func (this *Header) Context(ctx context.Context) context.Context

func (this *Header) Del(key string)

func (this *Header) ForeachKey(handler func(key, val string) error) error

func (this *Header) Get(key string) string

func (this *Header) Len() int

func (this *Header) Raw() metadata.MD

func (this *Header) Set(key, value string)

type Registry ¶

type Registry interface {
	Scheme() string

	Register(ctx context.Context, domain, service, node, addr string, ttl int64) (key string, err error)

	Unregister(ctx context.Context, domain, service, node string) (err error)

	BuildPath(domain, service, node string) string

	Close()
}

type Server ¶

type Server struct {
	// contains filtered or unexported fields
}

func NewServer ¶

func NewServer(domain, service, node string, registry Registry, opts ...grpc.ServerOption) (*Server, error)

func (*Server) Addr ¶

func (this *Server) Addr() string

func (*Server) Domain ¶

func (this *Server) Domain() string

func (*Server) GracefulStop ¶

func (this *Server) GracefulStop()

func (*Server) Name ¶

func (this *Server) Name() string

func (*Server) Node ¶

func (this *Server) Node() string

func (*Server) RegisterService ¶

func (this *Server) RegisterService(desc *grpc.ServiceDesc, impl interface{})

func (*Server) Registry ¶

func (this *Server) Registry() Registry

func (*Server) Run ¶

func (this *Server) Run() error

func (*Server) Server ¶

func (this *Server) Server() *grpc.Server

func (*Server) Service ¶

func (this *Server) Service() string

func (*Server) Stop ¶

func (this *Server) Stop()

type ServerOption ¶

type ServerOption struct {
	grpc.EmptyServerOption
	// contains filtered or unexported fields
}

func WithAddress ¶

func WithAddress(addr string) ServerOption

func WithRegisterTTL ¶

func WithRegisterTTL(ttl int64) ServerOption

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
balancer
ketama Module
examples module
interceptor
logging
ratelimit
recovery
retry
timeout
tracing
wrapper
breaker/hystrix Module
registry
etcd Module

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

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func WithInsecure ¶ added in v0.0.20

Types ¶

type ClientConn ¶

func Dial ¶

func (*ClientConn) Close ¶

func (*ClientConn) Invoke ¶

func (*ClientConn) NewStream ¶

func (*ClientConn) Prepare ¶

type ClientPool ¶

func NewClientPool ¶

func (*ClientPool) Close ¶

func (*ClientPool) Get ¶

func (*ClientPool) Prepare ¶

type DialFun ¶

type DialOption ¶

func WithPoolSize ¶

func WithTimeout ¶

type Header ¶

func HeaderFromIncoming ¶

func HeaderFromMetadata ¶

func HeaderFromOutgoing ¶

func NewHeader ¶

func (*Header) Context ¶

func (*Header) Del ¶

func (*Header) ForeachKey ¶

func (*Header) Get ¶

func (*Header) Len ¶

func (*Header) Raw ¶

func (*Header) Set ¶

type Registry ¶

type Server ¶

func NewServer ¶

func (*Server) Addr ¶

func (*Server) Domain ¶

func (*Server) GracefulStop ¶

func (*Server) Name ¶

func (*Server) Node ¶

func (*Server) RegisterService ¶

func (*Server) Registry ¶

func (*Server) Run ¶

func (*Server) Server ¶

func (*Server) Service ¶

func (*Server) Stop ¶

type ServerOption ¶

func WithAddress ¶

func WithRegisterTTL ¶

Source Files ¶

Directories ¶