grpc

package

v0.0.0-...-f59cc51 Latest Latest Go to latest Published: Oct 8, 2021 License: Apache-2.0 Imports: 18 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/zouchunxu/gof

Links

Open Source Insights

Documentation ¶

Index ¶

func SetGlobalBalancer(scheme string, selector selector.Selector)
type Builder
- func (b *Builder) Build(info base.PickerBuildInfo) gBalancer.Picker
type GofBuilder
- func (g *GofBuilder) Build(info base.PickerBuildInfo) gBalancer.Picker
type GofPicker
- func (g *GofPicker) Pick(info gBalancer.PickInfo) (gBalancer.PickResult, error)
type GofTrailer
- func (g GofTrailer) Get(key string) string
type GrpcServer
- func NewGrpcServer(addr string, mid ...grpc.UnaryServerInterceptor) *GrpcServer
type Picker
- func (p *Picker) Pick(info gBalancer.PickInfo) (gBalancer.PickResult, error)
type Trailer
- func (t Trailer) Get(k string) string
type Transport

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func SetGlobalBalancer ¶

func SetGlobalBalancer(scheme string, selector selector.Selector)

SetGlobalBalancer set grpc balancer with scheme.

Types ¶

type Builder ¶

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

Builder is grpc balancer builder.

func (*Builder) Build ¶

func (b *Builder) Build(info base.PickerBuildInfo) gBalancer.Picker

Build creates a grpc Picker.

type GofBuilder ¶

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

func (*GofBuilder) Build ¶

func (g *GofBuilder) Build(info base.PickerBuildInfo) gBalancer.Picker

type GofPicker ¶

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

func (*GofPicker) Pick ¶

func (g *GofPicker) Pick(info gBalancer.PickInfo) (gBalancer.PickResult, error)

type GofTrailer ¶

type GofTrailer metadata.MD

func (GofTrailer) Get ¶

func (g GofTrailer) Get(key string) string

type GrpcServer ¶

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

func NewGrpcServer ¶

func NewGrpcServer(addr string, mid ...grpc.UnaryServerInterceptor) *GrpcServer

func (*GrpcServer) Endpoint ¶

func (g *GrpcServer) Endpoint() (*url.URL, error)

Endpoint return a real address to registry endpoint. examples:

grpc://127.0.0.1:9000?isSecure=false

func (*GrpcServer) Start ¶

func (g *GrpcServer) Start(context.Context) error

func (*GrpcServer) Stop ¶

func (g *GrpcServer) Stop(context.Context) error

type Picker ¶

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

Picker is a grpc picker.

func (*Picker) Pick ¶

func (p *Picker) Pick(info gBalancer.PickInfo) (gBalancer.PickResult, error)

Pick pick instances.

type Trailer ¶

type Trailer metadata.MD

Trailer is a grpc trailder MD.

func (Trailer) Get ¶

func (t Trailer) Get(k string) string

Get get a grpc trailer value.

type Transport ¶

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

Transport is a gRPC transport.

func (*Transport) Endpoint ¶

func (tr *Transport) Endpoint() string

Endpoint returns the transport endpoint.

func (*Transport) Kind ¶

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

Kind returns the transport kind.

func (*Transport) Operation ¶

func (tr *Transport) Operation() string

Operation returns the transport operation.

func (*Transport) ReplyHeader ¶

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

ReplyHeader returns the reply header.

func (*Transport) RequestHeader ¶

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

RequestHeader returns the request header.

Source Files ¶

View all Source files

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