micro

Documentation

Index

• type Client
  • func NewClient(opts ...ClientOption) (*Client, error)
  • func (c *Client) Dial(ctx context.Context, serviceName string) (*grpc.ClientConn, error)
• type ClientOption
  • func ClientWithBalancer(balancer string) ClientOption
  • func ClientWithInsecure(insecure bool) ClientOption
  • func ClientWithRegistry(r registry.Registry) ClientOption
• type GrpcResolverBuilder
  • func NewRegisterBuilder(r registry.Registry, opts ...GrpcResolverBuilderOption) *GrpcResolverBuilder
  • func (b *GrpcResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (b *GrpcResolverBuilder) Scheme() string
• type GrpcResolverBuilderOption
  • func GrpcResolverBuilderWithTimeOut(timeOut time.Duration) GrpcResolverBuilderOption
• type Server
  • func NewServer(name string, opts ...ServerOpt) *Server
  • func (s *Server) Close() error
  • func (s *Server) Start(addr string) error
• type ServerOpt
  • func ServerWithGroupName(group string) ServerOpt
  • func ServerWithRegistry(r registry.Registry) ServerOpt
  • func ServerWithWeight(weight uint32) ServerOpt

Types

type Client

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

func NewClient

func NewClient(opts ...ClientOption) (*Client, error)

func (*Client) Dial

func (c *Client) Dial(ctx context.Context, serviceName string) (*grpc.ClientConn, error)

type ClientOption

type ClientOption func(c *Client)

func ClientWithBalancer

func ClientWithBalancer(balancer string) ClientOption

func ClientWithInsecure

func ClientWithInsecure(insecure bool) ClientOption

func ClientWithRegistry

func ClientWithRegistry(r registry.Registry) ClientOption

type GrpcResolverBuilder

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

func NewRegisterBuilder

func NewRegisterBuilder(r registry.Registry, opts ...GrpcResolverBuilderOption) *GrpcResolverBuilder

func (*GrpcResolverBuilder) Build

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

func (*GrpcResolverBuilder) Scheme

func (b *GrpcResolverBuilder) Scheme() string

type GrpcResolverBuilderOption

type GrpcResolverBuilderOption func(b *GrpcResolverBuilder)

func GrpcResolverBuilderWithTimeOut

func GrpcResolverBuilderWithTimeOut(timeOut time.Duration) GrpcResolverBuilderOption

type Server

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

func NewServer

func NewServer(name string, opts ...ServerOpt) *Server

func (*Server) Close

func (s *Server) Close() error

func (*Server) Start

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

type ServerOpt

type ServerOpt func(s *Server)

func ServerWithGroupName

func ServerWithGroupName(group string) ServerOpt

func ServerWithRegistry

func ServerWithRegistry(r registry.Registry) ServerOpt

func ServerWithWeight

func ServerWithWeight(weight uint32) ServerOpt