grpc_service

Documentation

Index

• Constants
• Variables
• func Close() error
• func NewPlugin(_ context.Context) application.Plugin
• func Register(ctx context.Context, endpoint string, mds ...Metadata) error
• func RegisterEtcdResolverBuilder(ctx context.Context, client *clientv3.Client, namespace string) resolver.Builder
• func RegisterNacosResolverBuilder(ctx context.Context, client naming_client.INamingClient) resolver.Builder
• func RegistryClientType(typeName string, fn InitRegisterFunc)
• func SetDefaultRegister(r RegisterInterface)
• func Unregister(ctx context.Context, endpoint string, mds ...Metadata) error
• type EtcdRegister
  • func (e *EtcdRegister) Close() error
  • func (e *EtcdRegister) Register(ctx context.Context, service Metadata, endpoint string) (err error)
  • func (e *EtcdRegister) Unregister(ctx context.Context, service Metadata, endpoint string) error
• type EtcdResolverBuilder
  • func (e *EtcdResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, _ resolver.BuildOptions) (resolver.Resolver, error)
  • func (e *EtcdResolverBuilder) Scheme() string
• type InitRegisterFunc
• type Metadata
  • func NewServiceMetadata(sd *grpc.ServiceDesc, svcVersion string) Metadata
• type NacosRegister
  • func (n *NacosRegister) Close() error
  • func (n *NacosRegister) Register(_ context.Context, service Metadata, endpoint string) error
  • func (n *NacosRegister) Unregister(_ context.Context, service Metadata, endpoint string) error
• type NacosResolverBuilder
  • func (n *NacosResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (n *NacosResolverBuilder) RegisterService(_ context.Context, service Metadata, endpoint string) error
  • func (n *NacosResolverBuilder) Scheme() string
  • func (n *NacosResolverBuilder) UnregisterService(_ context.Context, service Metadata, endpoint string) error
• type Plugin
  • func (p *Plugin) Config(ctx context.Context, conf []byte) error
  • func (p *Plugin) Init(ctx context.Context) error
  • func (p *Plugin) Run(ctx context.Context) error
• type RegisterInterface
  • func NewEtcdRegister(ctx context.Context, client *clientv3.Client, namespace string, ttl int64) RegisterInterface
  • func NewNacosRegister(ctx context.Context, client naming_client.INamingClient, groupName string) RegisterInterface
• type RegisterServices
  • func (r *RegisterServices) Del(instance Metadata, endpoint string)
  • func (r *RegisterServices) Put(instance Metadata, endpoint string)
  • func (r *RegisterServices) Range(fn func(instance Metadata, endpoint string) error) error
• type ServiceInfo
  • func (e *ServiceInfo) Del(endpoint string)
  • func (e *ServiceInfo) IsEmpty() bool
  • func (e *ServiceInfo) Put(endpoint string)

Constants

const ResolverEtcdScheme = "neptune-etcd"

const ResolverNacosScheme = "neptune-nacos"

Variables

var DefaultEtcdTTL int64 = 10

Functions

func Close

func Close() error

Close 关闭默认注册器

func NewPlugin

func NewPlugin(_ context.Context) application.Plugin

NewPlugin 服务注册、服务发现组件

func Register

func Register(ctx context.Context, endpoint string, mds ...Metadata) error

Register 使用默认注册器注册服务

func RegisterEtcdResolverBuilder

func RegisterEtcdResolverBuilder(ctx context.Context, client *clientv3.Client, namespace string) resolver.Builder

RegisterEtcdResolverBuilder 创建一个etcd解析器构建器，解析器schema为 ResolverEtcdScheme

func RegisterNacosResolverBuilder

func RegisterNacosResolverBuilder(ctx context.Context, client naming_client.INamingClient) resolver.Builder

RegisterNacosResolverBuilder 创建一个nacos解析器构建器，解析器schema为 ResolverEtcdScheme

func RegistryClientType

func RegistryClientType(typeName string, fn InitRegisterFunc)

func SetDefaultRegister

func SetDefaultRegister(r RegisterInterface)

func Unregister

func Unregister(ctx context.Context, endpoint string, mds ...Metadata) error

Unregister 使用默认注册器注销服务

Types

type EtcdRegister

type EtcdRegister struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*EtcdRegister) Close

func (e *EtcdRegister) Close() error

func (*EtcdRegister) Register

func (e *EtcdRegister) Register(ctx context.Context, service Metadata, endpoint string) (err error)

func (*EtcdRegister) Unregister

func (e *EtcdRegister) Unregister(ctx context.Context, service Metadata, endpoint string) error

type EtcdResolverBuilder

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

func (*EtcdResolverBuilder) Build

func (e *EtcdResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, _ resolver.BuildOptions) (resolver.Resolver, error)

func (*EtcdResolverBuilder) Scheme

func (e *EtcdResolverBuilder) Scheme() string

type InitRegisterFunc

type InitRegisterFunc func(ctx context.Context, conf *config.Config) error

type Metadata

type Metadata interface {
	ServiceDesc() *grpc.ServiceDesc
	Version() string
	UniqueKey() string
}

func NewServiceMetadata

func NewServiceMetadata(sd *grpc.ServiceDesc, svcVersion string) Metadata

type NacosRegister

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

func (*NacosRegister) Close

func (n *NacosRegister) Close() error

func (*NacosRegister) Register

func (n *NacosRegister) Register(_ context.Context, service Metadata, endpoint string) error

func (*NacosRegister) Unregister

func (n *NacosRegister) Unregister(_ context.Context, service Metadata, endpoint string) error

type NacosResolverBuilder

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

func (*NacosResolverBuilder) Build

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

func (*NacosResolverBuilder) RegisterService

func (n *NacosResolverBuilder) RegisterService(_ context.Context, service Metadata, endpoint string) error

func (*NacosResolverBuilder) Scheme

func (n *NacosResolverBuilder) Scheme() string

func (*NacosResolverBuilder) UnregisterService

func (n *NacosResolverBuilder) UnregisterService(_ context.Context, service Metadata, endpoint string) error

type Plugin

type Plugin struct {
	application.Plugin
	// contains filtered or unexported fields
}

func (*Plugin) Config

func (p *Plugin) Config(ctx context.Context, conf []byte) error

func (*Plugin) Init

func (p *Plugin) Init(ctx context.Context) error

func (*Plugin) Run

func (p *Plugin) Run(ctx context.Context) error

type RegisterInterface

type RegisterInterface interface {
	Register(ctx context.Context, service Metadata, endpoint string) error
	Unregister(ctx context.Context, service Metadata, endpoint string) error
	Close() error
}

func NewEtcdRegister

func NewEtcdRegister(ctx context.Context, client *clientv3.Client, namespace string, ttl int64) RegisterInterface

NewEtcdRegister 创建一个etcd注册器

func NewNacosRegister

func NewNacosRegister(ctx context.Context, client naming_client.INamingClient, groupName string) RegisterInterface

NewNacosRegister 创建一个nacos服务注册器

type RegisterServices

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

func (*RegisterServices) Del

func (r *RegisterServices) Del(instance Metadata, endpoint string)

func (*RegisterServices) Put

func (r *RegisterServices) Put(instance Metadata, endpoint string)

func (*RegisterServices) Range

func (r *RegisterServices) Range(fn func(instance Metadata, endpoint string) error) error

type ServiceInfo

type ServiceInfo struct {
	Item      Metadata
	Endpoints map[string]struct{}
}

func (*ServiceInfo) Del

func (e *ServiceInfo) Del(endpoint string)

func (*ServiceInfo) IsEmpty

func (e *ServiceInfo) IsEmpty() bool

func (*ServiceInfo) Put

func (e *ServiceInfo) Put(endpoint string)