grpc

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
  • func (g *GrpcServer) Endpoint() (*url.URL, error)
  • func (g *GrpcServer) Start(context.Context) error
  • func (g *GrpcServer) Stop(context.Context) error
• type Picker
  • func (p *Picker) Pick(info gBalancer.PickInfo) (gBalancer.PickResult, error)
• type Trailer
  • func (t Trailer) Get(k string) string
• type Transport
  • func (tr *Transport) Endpoint() string
  • func (tr *Transport) Kind() server.Kind
  • func (tr *Transport) Operation() string
  • func (tr *Transport) ReplyHeader() server.Header
  • func (tr *Transport) RequestHeader() server.Header

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.