goo_grpc

Mar 18, 2024

Changes in this version

type Config

+ ServiceEndpoint string

Sep 13, 2022

Changes in this version

+ func DialContext(ctx context.Context, addr string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

+ func DialContextWithEtcd(ctx context.Context, serviceName string, cli *goo_etcd.Client) (*grpc.ClientConn, error)

May 30, 2022

Changes in this version

+ type AuthFunc func(md metadata.MD, ctx context.Context, fullMethod string) (context.Context, error)

+ type PProf struct

type Server

+ func (s *Server) Register2ETCD(cli *goo_etcd.Client) error

+ type ServerOption interface

+ func AuthFuncOption(authFunc AuthFunc) ServerOption

+ func ServerOptions(opt ...grpc.ServerOption) ServerOption

Apr 2, 2022

Changes in this version

type Config

+ PProfAddr string

+ PProfEnable bool

Apr 1, 2022

Changes in this version

type Config

+ DebugAddr string

Nov 3, 2021

Changes in this version

+ func DialWithEtcd(ctx context.Context, serviceName string, cli *goo_etcd.Client) (*grpc.ClientConn, error)

+ type Config struct

+ Addr string

+ ENV string

+ ServiceName string

+ Version string

+ type Option struct

+ Name string

+ Value interface{}

+ func EnvOption(env string) Option

+ func EtcdOption(cli *goo_etcd.Client) Option

+ func ProjectNameOption(projectName string) Option

+ func ServiceNameOption(serviceName string) Option

+ func VersionOption(version string) Option

+ type ResolverEtcd struct

+ func NewResolverEtcd(ctx context.Context, cli *goo_etcd.Client) *ResolverEtcd

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

+ func (b *ResolverEtcd) Scheme() string

type Server

+ func (s *Server) Register2Etcd(cli *goo_etcd.Client) *Server

Oct 27, 2021

Changes in this version

+ 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 struct

+ 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 struct

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

+ func (g *GRPCGraceful) Serve() error

+ type Health struct

+ 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 struct

+ func (r *Resolver) Close()

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

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

+ type ResolverBuilder struct

+ 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 struct

+ func New() *Server

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