eidola

README

eidola

Documentation

Index

• type Client
  • func NewClient(opts ...ClientOption) (*Client, error)
  • func (c *Client) Dial(ctx context.Context, target string, dialOptions ...grpc.DialOption) (*grpc.ClientConn, error)
• type ClientOption
  • func ClientInsecure() ClientOption
  • func ClientWithPickerBuilder(name string, b base.PickerBuilder) ClientOption
  • func ClientWithResolver(registry registry.Registry, timeout time.Duration) ClientOption
• type GrpcResolverBuilder
  • func NewRegistryBuilder(registry registry.Registry, opts ...GrpcResolverOptions) (*GrpcResolverBuilder, error)
  • func (b *GrpcResolverBuilder) Build(target resolver.Target, clientConn resolver.ClientConn, ...) (resolver.Resolver, error)
  • func (b *GrpcResolverBuilder) Scheme() string
• type GrpcResolverOptions
  • func RegistryWithTimeout(timeout time.Duration) GrpcResolverOptions
• type Server
  • func NewServer(name string, opts ...ServerOption) (*Server, error)
  • func (s *Server) Close() error
  • func (s *Server) Start(addr string) error
• type ServerOption
  • func ServerWithGroup(group string) ServerOption
  • func ServerWithRegisterTimeout(d time.Duration) ServerOption
  • func ServerWithRegistry(reg registry.Registry) ServerOption
  • func ServerWithWeight(weight uint32) ServerOption

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, target string, dialOptions ...grpc.DialOption) (*grpc.ClientConn, error)

type ClientOption

type ClientOption func(c *Client)

func ClientInsecure

func ClientInsecure() ClientOption

func ClientWithPickerBuilder

func ClientWithPickerBuilder(name string, b base.PickerBuilder) ClientOption

func ClientWithResolver

func ClientWithResolver(registry registry.Registry, timeout time.Duration) ClientOption

type GrpcResolverBuilder

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

func NewRegistryBuilder

func NewRegistryBuilder(registry registry.Registry, opts ...GrpcResolverOptions) (*GrpcResolverBuilder, error)

func (*GrpcResolverBuilder) Build

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

func (*GrpcResolverBuilder) Scheme

func (b *GrpcResolverBuilder) Scheme() string

type GrpcResolverOptions

type GrpcResolverOptions func(r *GrpcResolverBuilder)

func RegistryWithTimeout

func RegistryWithTimeout(timeout time.Duration) GrpcResolverOptions

type Server

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

func NewServer

func NewServer(name string, opts ...ServerOption) (*Server, error)

func (*Server) Close

func (s *Server) Close() error

func (*Server) Start

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

type ServerOption

type ServerOption func(s *Server)

func ServerWithGroup

func ServerWithGroup(group string) ServerOption

func ServerWithRegisterTimeout

func ServerWithRegisterTimeout(d time.Duration) ServerOption

func ServerWithRegistry

func ServerWithRegistry(reg registry.Registry) ServerOption

func ServerWithWeight

func ServerWithWeight(weight uint32) ServerOption