goo_grpc

Documentation

Index

• func Context(c *gin.Context) context.Context
• func Dial(ctx context.Context, serviceName string, ch chan []resolver.Address, ...) (*grpc.ClientConn, error)
• func GRPCInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (rsp interface{}, err error)
• type Consul
  • func NewConsul(address, username, password string) *Consul
  • func (c *Consul) Client() (*api.Client, error)
  • func (c *Consul) Get(key string) ([]byte, error)
  • func (c *Consul) ServiceDeregister(serviceID string) error
  • func (c *Consul) ServiceRegister(key string) error
• type GRPCGraceful
  • func NewGRPCGraceful(nett, addr string, s *grpc.Server) *GRPCGraceful
  • func (g *GRPCGraceful) Serve() error
• type Health
  • func (Health) Check(context.Context, *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (Health) Watch(*grpc_health_v1.HealthCheckRequest, grpc_health_v1.Health_WatchServer) error
• type Resolver
  • func (r *Resolver) Close()
  • func (r *Resolver) ResolveNow(o resolver.ResolveNowOptions)
  • func (r *Resolver) Watch(ch chan []resolver.Address)
• type ResolverBuilder
  • func NewResolverBuilder(ctx context.Context, ch chan []resolver.Address) *ResolverBuilder
  • func (b *ResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (b *ResolverBuilder) Scheme() string
• type Server
  • func New() *Server
  • func (s *Server) Serve(addr string) error

Functions

func Context

func Context(c *gin.Context) context.Context

func Dial

func Dial(ctx context.Context, serviceName string, ch chan []resolver.Address, opts ...grpc.DialOption) (*grpc.ClientConn, error)

返回客户端对象

func GRPCInterceptor

func GRPCInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (rsp interface{}, err error)

Types

type Consul

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

func NewConsul

func NewConsul(address, username, password string) *Consul

func (*Consul) Client

func (c *Consul) Client() (*api.Client, error)

func (*Consul) Get

func (c *Consul) Get(key string) ([]byte, error)

func (*Consul) ServiceDeregister

func (c *Consul) ServiceDeregister(serviceID string) error

func (*Consul) ServiceRegister

func (c *Consul) ServiceRegister(key string) error

type GRPCGraceful

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

func NewGRPCGraceful

func NewGRPCGraceful(nett, addr string, s *grpc.Server) *GRPCGraceful

func (*GRPCGraceful) Serve

func (g *GRPCGraceful) Serve() error

type Health

type Health struct{}

func (Health) Check

func (Health) Check(context.Context, *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

func (Health) Watch

func (Health) Watch(*grpc_health_v1.HealthCheckRequest, grpc_health_v1.Health_WatchServer) error

type Resolver

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

func (*Resolver) Close

func (r *Resolver) Close()

func (*Resolver) ResolveNow

func (r *Resolver) ResolveNow(o resolver.ResolveNowOptions)

func (*Resolver) Watch

func (r *Resolver) Watch(ch chan []resolver.Address)

监测并更新grpc节点变化

type ResolverBuilder

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

func NewResolverBuilder

func NewResolverBuilder(ctx context.Context, ch chan []resolver.Address) *ResolverBuilder

func (*ResolverBuilder) Build

func (b *ResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

func (*ResolverBuilder) Scheme

func (b *ResolverBuilder) Scheme() string

type Server

type Server struct {
	*grpc.Server
}

func New

func New() *Server

func (*Server) Serve

func (s *Server) Serve(addr string) error