micro

Documentation

Index

• func AddConsumer(consumer Consumer) (err error)
• func DeleteConsumer(serviceName string)
• func GetServiceConn(serviceName string) (conn *grpc.ClientConn, err error)
• func StartProvide(provider Provider, port string) (err error)
• func Stop()
• type Consumer
• type GrpcRegisterFunc
• type NacosConsumer
  • func CreateNacosConsumer(clientConfig *constant.ClientConfig, serverConfigs *[]constant.ServerConfig, ...) (consumer *NacosConsumer, err error)
  • func (nc *NacosConsumer) CreateNacosProvider(foo GrpcRegisterFunc, ServiceName string) (provider *NacosProvider, err error)
  • func (nc *NacosConsumer) GetServiceConnection(serviceName string) (conn *grpc.ClientConn, err error)
  • func (nc *NacosConsumer) GetServiceName() (serviceName string, err error)
  • func (nc *NacosConsumer) Stop() (err error)
• type NacosProvider
  • func CreateNacosProvider(foo GrpcRegisterFunc, clientConfig *constant.ClientConfig, ...) (provider *NacosProvider, err error)
  • func (np *NacosProvider) CreateNacosConsumer(ServiceName string) (consumer *NacosConsumer)
  • func (np *NacosProvider) DeregisterServices() (err error)
  • func (np *NacosProvider) GetServiceName() (serviceName string)
  • func (np *NacosProvider) RegisterServices(s *grpc.Server, port string) (err error)
• type Provider

Functions

func AddConsumer

func AddConsumer(consumer Consumer) (err error)

func DeleteConsumer

func DeleteConsumer(serviceName string)

func GetServiceConn

func GetServiceConn(serviceName string) (conn *grpc.ClientConn, err error)

func StartProvide

func StartProvide(provider Provider, port string) (err error)

在指定端口监听微服务，并将端口注册给注册中心

func Stop

func Stop()

Types

type Consumer

type Consumer interface {
	GetServiceConnection(serviceName string) (conn *grpc.ClientConn, err error)
	GetServiceName() (serviceName string, err error)
	Stop() (err error)
}

type GrpcRegisterFunc

type GrpcRegisterFunc func(s *grpc.Server)

type NacosConsumer

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

func CreateNacosConsumer

func CreateNacosConsumer(clientConfig *constant.ClientConfig, serverConfigs *[]constant.ServerConfig, ServiceName string) (consumer *NacosConsumer, err error)

func (*NacosConsumer) CreateNacosProvider

func (nc *NacosConsumer) CreateNacosProvider(foo GrpcRegisterFunc, ServiceName string) (provider *NacosProvider, err error)

使用consumer的namingClient构建provider

func (*NacosConsumer) GetServiceConnection

func (nc *NacosConsumer) GetServiceConnection(serviceName string) (conn *grpc.ClientConn, err error)

func (*NacosConsumer) GetServiceName

func (nc *NacosConsumer) GetServiceName() (serviceName string, err error)

func (*NacosConsumer) Stop

func (nc *NacosConsumer) Stop() (err error)

type NacosProvider

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

func CreateNacosProvider

func CreateNacosProvider(foo GrpcRegisterFunc, clientConfig *constant.ClientConfig, serverConfigs *[]constant.ServerConfig, ServiceName string) (provider *NacosProvider, err error)

func (*NacosProvider) CreateNacosConsumer

func (np *NacosProvider) CreateNacosConsumer(ServiceName string) (consumer *NacosConsumer)

使用provider的namingClient构建consumer

func (*NacosProvider) DeregisterServices

func (np *NacosProvider) DeregisterServices() (err error)

func (*NacosProvider) GetServiceName

func (np *NacosProvider) GetServiceName() (serviceName string)

func (*NacosProvider) RegisterServices

func (np *NacosProvider) RegisterServices(s *grpc.Server, port string) (err error)

type Provider

type Provider interface {
	RegisterServices(s *grpc.Server, port string) (err error)
	GetServiceName() (serviceName string)
	DeregisterServices() (err error)
}