selector

Documentation

Index

• Constants
• func GetName(msgId int32) []string
• func Update(mds []*metaData)
• type Option
  • func Name(id, name string) Option
  • func Namespace(ns string) Option
  • func RegisterTTL(ttl time.Duration) Option
• type Options
• type Registry
  • func Initialize(ctx contextx.Context, client *clientv3.Client, opts ...Option) (r *Registry)
  • func (r *Registry) Register(msgIds []int32) error

Constants

const Prefix = "/pbserver"

Functions

func GetName

func GetName(msgId int32) []string

func Update

func Update(mds []*metaData)

Types

type Option

type Option func(o *Options)

Option is etcd registry option.

func Name

func Name(id, name string) Option

func Namespace

func Namespace(ns string) Option

Namespace with registry namespance.

func RegisterTTL

func RegisterTTL(ttl time.Duration) Option

RegisterTTL with Register TTL.

type Options

type Options struct {
	Id        string
	Namespace string
	Name      string
	Ttl       time.Duration
}

type Registry

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

Registry is etcd registry.

func Initialize

func Initialize(ctx contextx.Context, client *clientv3.Client, opts ...Option) (r *Registry)

func (*Registry) Register

func (r *Registry) Register(msgIds []int32) error