gxregistry

package
v0.3.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 9, 2020 License: Apache-2.0 Imports: 14 Imported by: 6

Documentation

Overview

Package gxregistry provides a interface for service register/discovery

Package gxregistry provides a interface for service register/discovery 

Package gxregistry is a generated protocol buffer package.

It is generated from these files:
	service.proto

It has these top-level messages:
	ServiceAttr
	Node
	Service
	EventResult

Package gxregistry provides a interface for service register/discovery

Index

Constants

View Source 
const (
	REGISTRY_CONN_DELAY = 3 // watchDir中使用，防止不断地对zk重连
	DefaultTimeout      = 3e9
	MaxFailTime         = 15e9 // fail retry wait time delay
)

Variables

View Source 
var (
	ErrorRegistryNotFound = jerrors.Errorf("registry not found")
	ErrorAlreadyRegister  = jerrors.Errorf("service has already been registered")
	DefaultServiceRoot    = "/gxregistry"
)
View Source 
var (
	ErrInvalidLengthService = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrWatcherClosed = jerrors.Errorf("Watcher closed")
)
View Source 
var ServiceEventType_name = map[int32]string{
	0: "SET_UNKNOWN",
	1: "ServiceAdd",
	2: "ServiceDel",
	3: "ServiceUpdate",
}
View Source 
var ServiceEventType_value = map[string]int32{
	"SET_UNKNOWN":   0,
	"ServiceAdd":    1,
	"ServiceDel":    2,
	"ServiceUpdate": 3,
}
View Source 
var ServiceRoleType_name = map[int32]string{
	0: "SRT_UNKOWN",
	1: "SRT_Provider",
	2: "SRT_Consumer",
}
View Source 
var ServiceRoleType_value = map[string]int32{
	"SRT_UNKOWN":   0,
	"SRT_Provider": 1,
	"SRT_Consumer": 2,
}

Functions

func EncodeService 

func EncodeService(s *Service) (string, error)

Types

type EventResult 

type EventResult struct {
	Action  ServiceEventType `protobuf:"varint,1,opt,name=Action,proto3,enum=gxregistry.ServiceEventType" json:"Action,omitempty"`
	Service *Service         `protobuf:"bytes,2,opt,name=Service" json:"Service,omitempty"`
}

Result is returned by a call to Next on the watcher. Actions can be create, update, delete

func (*EventResult) Descriptor 

func (*EventResult) Descriptor() ([]byte, []int)

func (*EventResult) Equal 

func (this *EventResult) Equal(that interface{}) bool

func (*EventResult) GoString 

func (this *EventResult) GoString() string

func (*EventResult) Marshal 

func (m *EventResult) Marshal() (dAtA []byte, err error)

func (*EventResult) MarshalTo 

func (m *EventResult) MarshalTo(dAtA []byte) (int, error)

func (*EventResult) ProtoMessage 

func (*EventResult) ProtoMessage()

func (*EventResult) Reset 

func (m *EventResult) Reset()

func (*EventResult) Size 

func (m *EventResult) Size() (n int)

func (*EventResult) String 

func (this *EventResult) String() string

func (*EventResult) Unmarshal 

func (m *EventResult) Unmarshal(dAtA []byte) error

func (*EventResult) VerboseEqual 

func (this *EventResult) VerboseEqual(that interface{}) error

type Node 

type Node struct {
	ID       string            `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Address  string            `protobuf:"bytes,2,opt,name=Address,proto3" json:"Address,omitempty"`
	Port     int32             `protobuf:"varint,3,opt,name=Port,proto3" json:"Port,omitempty"`
	Metadata map[string]string `` /* 150-byte string literal not displayed */
}

func (*Node) Copy 

func (m *Node) Copy() *Node

func (*Node) Descriptor 

func (*Node) Descriptor() ([]byte, []int)

func (*Node) Equal 

func (this *Node) Equal(that interface{}) bool

func (*Node) GoString 

func (this *Node) GoString() string

func (*Node) Marshal 

func (m *Node) Marshal() (dAtA []byte, err error)

func (*Node) MarshalTo 

func (m *Node) MarshalTo(dAtA []byte) (int, error)

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

func (m *Node) Size() (n int)

func (*Node) String 

func (this *Node) String() string

func (*Node) Unmarshal 

func (m *Node) Unmarshal(dAtA []byte) error

func (*Node) VerboseEqual 

func (this *Node) VerboseEqual(that interface{}) error

type NodeMeta added in v0.3.1 

type NodeMeta func(*Node)

func WithNodeMeta added in v0.3.1 

func WithNodeMeta(key, value string) NodeMeta

type Option 

type Option func(*Options)

func WithAddrs 

func WithAddrs(addrs ...string) Option

Addrs is the registry addresses to use

func WithRoot 

func WithRoot(root string) Option

func WithTimeout 

func WithTimeout(t time.Duration) Option

type Options 

type Options struct {
	Addrs   []string
	Timeout time.Duration
	Root    string
}

type Registry 

type Registry interface {
	Register(service Service) error
	Deregister(service Service) error
	GetServices(attr ServiceAttr) ([]Service, error)
	Watch(opts ...WatchOption) (Watcher, error)
	Close() error
	String() string
	Options() Options
}

Registry provides an interface for service register

type Service 

type Service struct {
	Attr     *ServiceAttr      `protobuf:"bytes,1,opt,name=Attr" json:"Attr,omitempty"`
	Nodes    []*Node           `protobuf:"bytes,2,rep,name=Nodes" json:"Nodes,omitempty"`
	Metadata map[string]string `` /* 150-byte string literal not displayed */
}

func DecodeService 

func DecodeService(ds []byte) (*Service, error)

func (*Service) Copy 

func (s *Service) Copy() *Service

func (*Service) Descriptor 

func (*Service) Descriptor() ([]byte, []int)

func (*Service) Equal 

func (this *Service) Equal(that interface{}) bool

func (*Service) GoString 

func (this *Service) GoString() string

func (*Service) Marshal 

func (m *Service) Marshal() (dAtA []byte, err error)

func (*Service) MarshalTo 

func (m *Service) MarshalTo(dAtA []byte) (int, error)

func (*Service) NodePath 

func (s *Service) NodePath(root string, node Node) string

func (*Service) Path 

func (s *Service) Path(root string) string

/dubbo/group%3Dbjtelecom%26protocol%3Dpb%26service%3Dshopping%26type%3Dadd%2Bservice%26version%3D1.0.1/node1

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) Size 

func (m *Service) Size() (n int)

func (*Service) String 

func (this *Service) String() string

func (*Service) Unmarshal 

func (m *Service) Unmarshal(dAtA []byte) error

func (*Service) VerboseEqual 

func (this *Service) VerboseEqual(that interface{}) error

type ServiceAttr 

type ServiceAttr struct {
	Group    string          `protobuf:"bytes,1,opt,name=Group,proto3" json:"Group,omitempty"`
	Service  string          `protobuf:"bytes,2,opt,name=Service,proto3" json:"Service,omitempty"`
	Protocol string          `protobuf:"bytes,3,opt,name=Protocol,proto3" json:"Protocol,omitempty"`
	Version  string          `protobuf:"bytes,4,opt,name=Version,proto3" json:"Version,omitempty"`
	Role     ServiceRoleType `protobuf:"varint,5,opt,name=Role,proto3,enum=gxregistry.ServiceRoleType" json:"Role,omitempty"`
}

func (*ServiceAttr) Copy 

func (m *ServiceAttr) Copy() *ServiceAttr

func (*ServiceAttr) Descriptor 

func (*ServiceAttr) Descriptor() ([]byte, []int)

func (*ServiceAttr) Equal 

func (this *ServiceAttr) Equal(that interface{}) bool

func (*ServiceAttr) Filter 

func (m *ServiceAttr) Filter(service ServiceAttr) bool

fine filtering

func (*ServiceAttr) GoString 

func (this *ServiceAttr) GoString() string

func (*ServiceAttr) Marshal 

func (m *ServiceAttr) Marshal() (dAtA []byte, err error)

func (*ServiceAttr) MarshalPath 

func (a *ServiceAttr) MarshalPath() ([]byte, error)

func (*ServiceAttr) MarshalTo 

func (m *ServiceAttr) MarshalTo(dAtA []byte) (int, error)

func (*ServiceAttr) MeshFilter added in v0.3.1 

func (m *ServiceAttr) MeshFilter(service ServiceAttr) bool

func (*ServiceAttr) ProtoMessage 

func (*ServiceAttr) ProtoMessage()

func (*ServiceAttr) Reset 

func (m *ServiceAttr) Reset()

func (*ServiceAttr) Size 

func (m *ServiceAttr) Size() (n int)

func (*ServiceAttr) String 

func (this *ServiceAttr) String() string

func (*ServiceAttr) Unmarshal 

func (m *ServiceAttr) Unmarshal(dAtA []byte) error

func (*ServiceAttr) UnmarshalPath 

func (a *ServiceAttr) UnmarshalPath(data []byte) error

func (*ServiceAttr) VerboseEqual 

func (this *ServiceAttr) VerboseEqual(that interface{}) error

type ServiceEventType 

type ServiceEventType int32

//////////////////////////////////////// service url event type //////////////////////////////////////// 

const (
	SET_UNKNOWN   ServiceEventType = 0
	ServiceAdd    ServiceEventType = 1
	ServiceDel    ServiceEventType = 2
	ServiceUpdate ServiceEventType = 3
)

func (ServiceEventType) EnumDescriptor 

func (ServiceEventType) EnumDescriptor() ([]byte, []int)

func (ServiceEventType) String 

func (x ServiceEventType) String() string

type ServiceMeta added in v0.3.1 

type ServiceMeta func(*Service)

func WithServiceMeta added in v0.3.1 

func WithServiceMeta(key, value string) ServiceMeta

type ServiceRoleType 

type ServiceRoleType int32

//////////////////////////////////////// service role //////////////////////////////////////// 

const (
	SRT_UNKOWN   ServiceRoleType = 0
	SRT_Provider ServiceRoleType = 1
	SRT_Consumer ServiceRoleType = 2
)

func String2ServiceRoleType 

func String2ServiceRoleType(role string) ServiceRoleType

func (ServiceRoleType) EnumDescriptor 

func (ServiceRoleType) EnumDescriptor() ([]byte, []int)

func (ServiceRoleType) String 

func (x ServiceRoleType) String() string

type WatchOption 

type WatchOption func(*WatchOptions)

func WithWatchFilter 

func WithWatchFilter(filter ServiceAttr) WatchOption

Watch ServiceAttr Filter

func WithWatchRoot 

func WithWatchRoot(root string) WatchOption

Watch root

type WatchOptions 

type WatchOptions struct {
	// the root registry path, such as "/dubbo/"
	Root string
	// filter the second path, such as
	// "/test/group%3Dbjtelecom%26protocol%3Dpb%26role%3DSRT_Provider%26service%3Dshopping%26version%3D1.0.1"
	Filter ServiceAttr
}

type Watcher 

type Watcher interface {
	Notify() (*EventResult, error)
	Valid() bool // 检查watcher与registry连接是否正常
	Close()
	IsClosed() bool
}

Watcher provides an interface for service discovery

Source Files

View all Source files

Directories

Path Synopsis
Package gxetcd provides an etcd version 3 gxregistry Package gxetcd provides an etcd version 3 gxregistry ref: https://github.com/micro/go-plugins/blob/master/gxregistry/etcdv3/etcdv3.go
 Package gxetcd provides an etcd version 3 gxregistry Package gxetcd provides an etcd version 3 gxregistry ref: https://github.com/micro/go-plugins/blob/master/gxregistry/etcdv3/etcdv3.go
Package gxzookeeper provides a zookeeper registry Package gxzookeeper provides a zookeeper watcher
 Package gxzookeeper provides a zookeeper registry Package gxzookeeper provides a zookeeper watcher

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.