micro

Documentation

Index

• type Option
  • func WithDialTimeout(timeout time.Duration) Option
  • func WithEndpoints(endpoints []string) Option
  • func WithEtcdConfig(config *clientv3.Config) Option
  • func WithGrpcListener(listener net.Listener) Option
  • func WithGrpcServer(grpcSvr *grpc.Server) Option
  • func WithService(service *Service) Option
• type Server
  • func NewServer(opts ...Option) *Server
  • func (s *Server) GetEtcdClient() *clientv3.Client
  • func (s *Server) GetGrpcServer() *grpc.Server
  • func (s *Server) GetService() *Service
  • func (s *Server) Init() error
  • func (s *Server) RegisterService() error
  • func (s *Server) ServiceDiscovery(name string, opts ...grpc.DialOption) (*grpc.ClientConn, error)
  • func (s *Server) Start() error
  • func (s *Server) Stop()
  • func (s *Server) UnRegisterService() error
• type Service
  • func NewService(opts ...ServiceOption) *Service
• type ServiceOption
  • func WithServiceAddr(serviceAddr string) ServiceOption
  • func WithServiceName(serviceName string) ServiceOption

Types

type Option

type Option func(s *Server)

func WithDialTimeout

func WithDialTimeout(timeout time.Duration) Option

func WithEndpoints

func WithEndpoints(endpoints []string) Option

func WithEtcdConfig

func WithEtcdConfig(config *clientv3.Config) Option

func WithGrpcListener

func WithGrpcListener(listener net.Listener) Option

func WithGrpcServer

func WithGrpcServer(grpcSvr *grpc.Server) Option

func WithService

func WithService(service *Service) Option

type Server

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

func NewServer

func NewServer(opts ...Option) *Server

func (*Server) GetEtcdClient

func (s *Server) GetEtcdClient() *clientv3.Client

GetEtcdClient 获取etcd client

func (*Server) GetGrpcServer

func (s *Server) GetGrpcServer() *grpc.Server

GetGrpcServer 获取grpc server

func (*Server) GetService

func (s *Server) GetService() *Service

GetService 获取service

func (*Server) Init

func (s *Server) Init() error

func (*Server) RegisterService

func (s *Server) RegisterService() error

RegisterService 注册服务

func (*Server) ServiceDiscovery

func (s *Server) ServiceDiscovery(name string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

ServiceDiscovery 服务发现

func (*Server) Start

func (s *Server) Start() error

Start 启动grpc server

func (*Server) Stop

func (s *Server) Stop()

Stop 停止grpc server

func (*Server) UnRegisterService

func (s *Server) UnRegisterService() error

UnRegisterService 注销服务

type Service

type Service struct {
	// 服务名称
	ServiceName string
	// 服务地址
	ServiceAddr string
}

Service 服务

func NewService

func NewService(opts ...ServiceOption) *Service

type ServiceOption

type ServiceOption func(s *Service)

func WithServiceAddr

func WithServiceAddr(serviceAddr string) ServiceOption

func WithServiceName

func WithServiceName(serviceName string) ServiceOption