grpc

package

v1.11.0 Latest Latest Go to latest Published: Jan 31, 2024 License: MIT Imports: 24 Imported by: 0

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/apus-run/gaia

Links

Open Source Insights

Documentation ¶

Index ¶

func Dial(ctx context.Context, opts ...ClientOption) (*grpc.ClientConn, error)
func DialInsecure(ctx context.Context, opts ...ClientOption) (*grpc.ClientConn, error)
func NewWrappedStream(ctx context.Context, stream grpc.ServerStream) grpc.ServerStream
type Client
type ClientOption
type Server
- func NewServer(opts ...ServerOption) *Server
type ServerOption
type Transport

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Dial ¶

func Dial(ctx context.Context, opts ...ClientOption) (*grpc.ClientConn, error)

Dial returns a GRPC connection.

func DialInsecure ¶

func DialInsecure(ctx context.Context, opts ...ClientOption) (*grpc.ClientConn, error)

DialInsecure returns an insecure GRPC connection.

func NewWrappedStream ¶

func NewWrappedStream(ctx context.Context, stream grpc.ServerStream) grpc.ServerStream

Types ¶

type Client ¶

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

Client is gRPC Client

type ClientOption ¶

type ClientOption func(o *Client)

ClientOption is gRPC client option.

func WithBalancerName ¶

func WithBalancerName(name string) ClientOption

WithBalancerName with balancer name

func WithDiscovery ¶

func WithDiscovery(d registry.Discovery) ClientOption

WithDiscovery with client discovery.

func WithEndpoint ¶

func WithEndpoint(endpoint string) ClientOption

WithEndpoint ...

func WithGrpcOptions ¶

func WithGrpcOptions(opts ...grpc.DialOption) ClientOption

WithGrpcOptions with gRPC options.

func WithMiddleware ¶

func WithMiddleware(ms ...middleware.Middleware) ClientOption

WithMiddleware with client middleware.

func WithPrintDiscoveryDebugLog ¶

func WithPrintDiscoveryDebugLog(p bool) ClientOption

func WithStreamInterceptor ¶

func WithStreamInterceptor(in ...grpc.StreamClientInterceptor) ClientOption

WithStreamInterceptor returns a DialOption that specifies the interceptor for streaming RPCs.

func WithTLSConfig ¶

func WithTLSConfig(conf *tls.TLS) ClientOption

WithTLSConfig with TLS config.

func WithTimeout ¶

func WithTimeout(timeout time.Duration) ClientOption

WithTimeout with client timeout.

func WithUnaryInterceptor ¶

func WithUnaryInterceptor(in ...grpc.UnaryClientInterceptor) ClientOption

WithUnaryInterceptor returns a DialOption that specifies the interceptor for unary RPCs.

type Server ¶

type Server struct {
	*grpc.Server
	// contains filtered or unexported fields
}

Server is a gRPC server wrapper.

func NewServer ¶

func NewServer(opts ...ServerOption) *Server

NewServer creates a gRPC server by options.

func (*Server) Endpoint ¶

func (s *Server) Endpoint() (*url.URL, error)

Endpoint return a real address to registry endpoint. examples:

grpc://127.0.0.1:9000?isSecure=false

func (*Server) Start ¶

func (s *Server) Start(ctx context.Context) error

Start start the gRPC server.

func (*Server) Stop ¶

func (s *Server) Stop(ctx context.Context) error

Stop stop the gRPC server.

func (*Server) Use ¶

func (s *Server) Use(selector string, m ...middleware.Middleware)

Use uses a service middleware with selector. selector:

'/*'
'/helloworld.v1.Greeter/*'
'/helloworld.v1.Greeter/SayHello'

type ServerOption ¶

type ServerOption func(o *Server)

ServerOption is gRPC server option.

func Address ¶

func Address(addr string) ServerOption

Address with server address.

func CustomHealth ¶ added in v1.9.1

func CustomHealth() ServerOption

CustomHealth Checks server.

func Endpoint ¶

func Endpoint(endpoint *url.URL) ServerOption

Endpoint with server address.

func GrpcOptions ¶

func GrpcOptions(opts ...grpc.ServerOption) ServerOption

GrpcOptions with grpc options.

func Listener ¶

func Listener(lis net.Listener) ServerOption

Listener with server lis

func Middleware ¶

func Middleware(m ...middleware.Middleware) ServerOption

Middleware with server middleware.

func Network ¶

func Network(network string) ServerOption

Network with server network.

func StreamInterceptor ¶

func StreamInterceptor(in ...grpc.StreamServerInterceptor) ServerOption

StreamInterceptor returns a ServerOption that sets the StreamServerInterceptor for the server.

func TLSConfig ¶

func TLSConfig(c *tls.TLS) ServerOption

TLSConfig with TLS config.

func Timeout ¶

func Timeout(timeout time.Duration) ServerOption

Timeout with server timeout.

func UnaryInterceptor ¶

func UnaryInterceptor(in ...grpc.UnaryServerInterceptor) ServerOption

UnaryInterceptor returns a ServerOption that sets the UnaryServerInterceptor for the server.

type Transport ¶

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

Transport is an HTTP transport.

func (*Transport) Endpoint ¶

func (tr *Transport) Endpoint() string

Endpoint returns the transport endpoint.

func (*Transport) Kind ¶

func (tr *Transport) Kind() transport.Kind

Kind returns the transport kind.

func (*Transport) Operation ¶

func (tr *Transport) Operation() string

Operation returns the transport operation.

func (*Transport) ReplyHeader ¶ added in v1.10.0

func (tr *Transport) ReplyHeader() transport.Header

ReplyHeader returns the reply header.

func (*Transport) RequestHeader ¶ added in v1.10.0

func (tr *Transport) RequestHeader() transport.Header

RequestHeader returns the request header.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
resolver
direct
discovery

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