grpc

package module

v3.10.17 Latest Latest Go to latest Published: Apr 23, 2024 License: Apache-2.0 Imports: 39 Imported by: 3

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

git.unistack.org/unistack-org/micro-server-grpc

Links

Open Source Insights

Documentation ¶

Overview ¶

Package grpc provides a grpc server

Index ¶

Constants
func Codec(contentType string, c encoding.Codec) server.Option
func MaxMsgSize(s int) server.Option
func Options(opts ...grpc.ServerOption) server.Option
func Reflection(r Reflector) server.Option
func UnknownServiceHandler(h grpc.StreamHandler) server.Option
type Reflector
type Server
- func NewServer(opts ...server.Option) *Server

Constants ¶

View Source

const (
	// ReflectV1ServiceName is the fully-qualified name of the v1 version of the reflection service.
	ReflectV1ServiceName = "grpc.reflection.v1.ServerReflection"
	// ReflectServiceURLPathV1 is the full path for reflection service endpoint
	ReflectServiceURLPathV1 = "/" + ReflectV1ServiceName + "/"
	// ReflectMethodName is the reflection service name
	ReflectMethodName = "ServerReflectionInfo"
)

View Source

const (
	DefaultContentType = "application/grpc"
)

Variables ¶

This section is empty.

Functions ¶

func Codec ¶

func Codec(contentType string, c encoding.Codec) server.Option

gRPC Codec to be used to encode/decode requests for a given content type

func MaxMsgSize ¶

func MaxMsgSize(s int) server.Option

MaxMsgSize set the maximum message in bytes the server can receive and send. Default maximum message size is 4 MB.

func Options ¶

func Options(opts ...grpc.ServerOption) server.Option

Options to be used to configure gRPC options

func Reflection ¶

func Reflection(r Reflector) server.Option

Reflection enables reflection support in grpc server

func UnknownServiceHandler ¶ added in v3.9.1

func UnknownServiceHandler(h grpc.StreamHandler) server.Option

UnknownServiceHandler enables support for all services

Types ¶

type Reflector ¶ added in v3.10.10

type Reflector interface {
	protodesc.Resolver
	reflection.ServiceInfoProvider
	reflection.ExtensionResolver
}

type Server ¶ added in v3.10.2

type Server struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewServer ¶

func NewServer(opts ...server.Option) *Server

func (*Server) Deregister ¶ added in v3.10.2

func (g *Server) Deregister() error

func (*Server) GRPCServer ¶ added in v3.10.2

func (g *Server) GRPCServer() *grpc.Server

func (*Server) Handle ¶ added in v3.10.2

func (g *Server) Handle(h server.Handler) error

func (*Server) Init ¶ added in v3.10.2

func (g *Server) Init(opts ...server.Option) error

func (*Server) Name ¶ added in v3.10.2

func (g *Server) Name() string

func (*Server) NewHandler ¶ added in v3.10.2

func (g *Server) NewHandler(h interface{}, opts ...server.HandlerOption) server.Handler

func (*Server) NewSubscriber ¶ added in v3.10.2

func (g *Server) NewSubscriber(topic string, sb interface{}, opts ...server.SubscriberOption) server.Subscriber

func (*Server) Options ¶ added in v3.10.2

func (g *Server) Options() server.Options

func (*Server) Register ¶ added in v3.10.2

func (g *Server) Register() error

func (*Server) Start ¶ added in v3.10.2

func (g *Server) Start() error

func (*Server) Stop ¶ added in v3.10.2

func (g *Server) Stop() error

func (*Server) String ¶ added in v3.10.2

func (g *Server) String() string

func (g *Server) Subscribe(sb server.Subscriber) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
proto

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