grpc

Documentation

Index

• Constants
• func Namespace() string
• func SetNamespace(ns string)
• type Builder
  • func NewBuilder(conf etcd.Config) *Builder
  • func (b *Builder) Build(target resolver.Target, conn resolver.ClientConn, opt resolver.BuildOptions) (resolver.Resolver, error)
  • func (b *Builder) Register() error
  • func (b *Builder) Scheme() string
  • func (b *Builder) Shutdown()
• type Instance
  • func (i *Instance) Address() resolver.Address
  • func (i *Instance) Decode(value string) error
  • func (i *Instance) Encode() (string, error)
  • func (i *Instance) Parse(addr resolver.Address)
  • func (i *Instance) Path() string
  • func (i *Instance) Prefix() string
  • func (i *Instance) Valid() bool
• type Register
  • func NewRegister(conf etcd.Config) *Register
  • func (r *Register) GetInstance() (*Instance, error)
  • func (r *Register) Register(ins *Instance, ttl int64) error
  • func (r *Register) Shutdown()
• type Resolver
  • func NewResolver(conn resolver.ClientConn, cli *etcd.Client, key string, prefix bool) *Resolver
  • func (r *Resolver) Close()
  • func (r *Resolver) Create(key, value string) error
  • func (r *Resolver) Delete(key, value string) error
  • func (r *Resolver) IsPrefix() bool
  • func (r *Resolver) Key() string
  • func (r *Resolver) Modify(key, value string) error
  • func (r *Resolver) ResolveNow(o resolver.ResolveNowOptions)
  • func (r *Resolver) Tick(t time.Time) error

Constants

const (
	Str_Empty = ""

	Default = "default"
)

const (
	Scheme_Etcd = "etcd"
)

Functions

func Namespace

func Namespace() string

func SetNamespace

func SetNamespace(ns string)

Types

type Builder

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

func NewBuilder

func NewBuilder(conf etcd.Config) *Builder

func (*Builder) Build

func (b *Builder) Build(target resolver.Target, conn resolver.ClientConn, opt resolver.BuildOptions) (resolver.Resolver, error)

func (*Builder) Register

func (b *Builder) Register() error

func (*Builder) Scheme

func (b *Builder) Scheme() string

func (*Builder) Shutdown

func (b *Builder) Shutdown()

type Instance

type Instance struct {
	Name      string `json:"n"`
	Addr      string `json:"a"`
	Version   string `json:"v"`
	Weight    int64  `json:"w"`
	Group     string `json:"g"`
	Namespace string `json:"ns"`
}

func (*Instance) Address

func (i *Instance) Address() resolver.Address

func (*Instance) Decode

func (i *Instance) Decode(value string) error

func (*Instance) Encode

func (i *Instance) Encode() (string, error)

func (*Instance) Parse

func (i *Instance) Parse(addr resolver.Address)

func (*Instance) Path

func (i *Instance) Path() string

func (*Instance) Prefix

func (i *Instance) Prefix() string

func (*Instance) Valid

func (i *Instance) Valid() bool

type Register

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

func NewRegister

func NewRegister(conf etcd.Config) *Register

func (*Register) GetInstance

func (r *Register) GetInstance() (*Instance, error)

func (*Register) Register

func (r *Register) Register(ins *Instance, ttl int64) error

func (*Register) Shutdown

func (r *Register) Shutdown()

type Resolver

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

func NewResolver

func NewResolver(conn resolver.ClientConn, cli *etcd.Client, key string, prefix bool) *Resolver

func (*Resolver) Close

func (r *Resolver) Close()

func (*Resolver) Create

func (r *Resolver) Create(key, value string) error

func (*Resolver) Delete

func (r *Resolver) Delete(key, value string) error

func (*Resolver) IsPrefix

func (r *Resolver) IsPrefix() bool

func (*Resolver) Key

func (r *Resolver) Key() string

func (*Resolver) Modify

func (r *Resolver) Modify(key, value string) error

func (*Resolver) ResolveNow

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

func (*Resolver) Tick

func (r *Resolver) Tick(t time.Time) error