service_manager

README

service_manager

服务管理系统 基于zookeeper

开始使用

服务生产者

import "github.com/ZR233/service_manager"

//zookeeper集群地址
zkHosts = ["192.168.0.2:2181", "192.168.0.3:2181"]
//服务名称
serviceName = "test_project/auth"
//服务地址
serviceHost = "localhost:9999"
service = service_manager.NewService(serviceName,
                          		serviceHost,
                          		zkHosts)
//服务注册，此函数不会阻塞
service.Open()

if err != nil {
    panic(err)
}
//服务注销
defer service.Close()

服务消费者

import "github.com/ZR233/service_manager"

zkHosts = ["192.168.0.2:2181", "192.168.0.3:2181"]
serviceName = "test_project/auth"
consumer = service_manager.NewConsumer(serviceName, zkHosts)
//Run()函数不会阻塞
consumer.Run()

address, err := consumer.GetServiceHost()
if err != nil {
    return
}

Documentation

Overview

@Time : 2019-10-08 16:28 @Author : zr

@Time : 2019-10-08 11:06 @Author : zr

@Time : 2019-10-14 10:16 @Author : zr

@Time : 2019-10-08 16:18 @Author : zr

Index

• Variables
• func GRpcConnTest() pool.ConnTestFunc
• func GetCurrentPath() (string, error)
• type ConnFactory
  • func GRpcFactory() ConnFactory
• type Consumer
  • func (c *Consumer) Close()
  • func (c *Consumer) GetConn() (conn io.Closer, err error)
  • func (c *Consumer) Open() (err error)
  • func (c *Consumer) ReleaseConn(conn io.Closer)
• type ConsumerOption
• type ConsumerOptionConnFactory
• type ConsumerOptionConnMax
• type ConsumerOptionConnMin
• type ConsumerOptionConnTestFunc
• type Logger
• type Manager
  • func NewManager(hosts []string) *Manager
  • func (m *Manager) Close() error
  • func (m *Manager) NewConsumer(service *Service, options ...ConsumerOption) (c *Consumer, err error)
  • func (m *Manager) NewProducer(service *Service, port int, options ...ProducerOption) (producer *Producer, err error)
  • func (m *Manager) NewService(sPath string, options ...ServiceOption) *Service
  • func (m *Manager) RunSync() (err error)
  • func (m *Manager) SetLogger(logger Logger)
• type NodeInfo
• type NodeRunningError
  • func (e *NodeRunningError) Error() string
  • func (e *NodeRunningError) Unwrap() error
• type OptionHost
• type Producer
  • func (p *Producer) Close() error
  • func (p *Producer) Open() (err error)
  • func (p *Producer) Status() Status
• type ProducerOption
• type Protocol
  • func (p Protocol) String() string
• type Service
• type ServiceOption
• type ServiceOptionProtocol
• type ServiceOptionServiceType
• type ServiceType
  • func (s ServiceType) String() string
• type Status
• type ZKError
  • func (z *ZKError) Error() string
  • func (z *ZKError) Unwrap() error

Variables

var (
	ErrNoService                 = errors.New("no service")
	ErrNoServiceAlive            = errors.New("no service alive")
	ErrHost                      = errors.New("host error")
	ErrConnectToZooKeeper        = zk.ErrNoServer
	ErrInvalidPath               = zk.ErrInvalidPath
	ErrSingletonServiceIsRunning = errors.New("service type is singleton and there is one already running")
)

Functions

func GRpcConnTest

func GRpcConnTest() pool.ConnTestFunc

func GetCurrentPath

func GetCurrentPath() (string, error)

Types

type ConnFactory

type ConnFactory func(host string) (io.Closer, error)

func GRpcFactory

func GRpcFactory() ConnFactory

type Consumer

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

func (*Consumer) Close

func (c *Consumer) Close()

func (*Consumer) GetConn

func (c *Consumer) GetConn() (conn io.Closer, err error)

func (*Consumer) Open

func (c *Consumer) Open() (err error)

func (*Consumer) ReleaseConn

func (c *Consumer) ReleaseConn(conn io.Closer)

type ConsumerOption

type ConsumerOption interface {
	// contains filtered or unexported methods
}

type ConsumerOptionConnFactory

type ConsumerOptionConnFactory ConnFactory

type ConsumerOptionConnMax

type ConsumerOptionConnMax int

type ConsumerOptionConnMin

type ConsumerOptionConnMin int

type ConsumerOptionConnTestFunc

type ConsumerOptionConnTestFunc pool.ConnTestFunc

type Logger

type Logger interface {
	Debug(args ...interface{})
	Info(args ...interface{})
	Warn(args ...interface{})
	Error(args ...interface{})
	Panic(args ...interface{})
}

type Manager

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

func NewManager

func NewManager(hosts []string) *Manager

func (*Manager) Close

func (m *Manager) Close() error

func (*Manager) NewConsumer

func (m *Manager) NewConsumer(service *Service, options ...ConsumerOption) (c *Consumer, err error)

func (*Manager) NewProducer

func (m *Manager) NewProducer(service *Service, port int, options ...ProducerOption) (producer *Producer, err error)

func (*Manager) NewService

func (m *Manager) NewService(sPath string, options ...ServiceOption) *Service

func (*Manager) RunSync

func (m *Manager) RunSync() (err error)

func (*Manager) SetLogger

func (m *Manager) SetLogger(logger Logger)

type NodeInfo

type NodeInfo struct {
	Pid      int
	Host     string
	HostName string
	Port     int
	ExecPath string
	// contains filtered or unexported fields
}

type NodeRunningError

type NodeRunningError struct {
	RunningHost string
	Err         error
}

func (*NodeRunningError) Error

func (e *NodeRunningError) Error() string

func (*NodeRunningError) Unwrap

func (e *NodeRunningError) Unwrap() error

type OptionHost

type OptionHost string

ipv6 地址 格式为 [::1234]

type Producer

type Producer struct {

	//public:
	NodeInfo
	// contains filtered or unexported fields
}

func (*Producer) Close

func (p *Producer) Close() error

func (*Producer) Open

func (p *Producer) Open() (err error)

func (*Producer) Status

func (p *Producer) Status() Status

type ProducerOption

type ProducerOption interface {
	// contains filtered or unexported methods
}

type Protocol

type Protocol int

const (
	ProtocolGRPC Protocol = iota
	ProtocolHttp
	ProtocolThrift
)

func (Protocol) String

func (p Protocol) String() string

type Service

type Service struct {
	Path     string `json:"-"`
	Protocol Protocol
	Type     ServiceType
}

type ServiceOption

type ServiceOption interface {
	// contains filtered or unexported methods
}

type ServiceOptionProtocol

type ServiceOptionProtocol Protocol

type ServiceOptionServiceType

type ServiceOptionServiceType ServiceType

type ServiceType

type ServiceType int

const (
	ServiceTypeNormal    ServiceType = iota
	ServiceTypeSingleton             //只允许运行一个实例
)

func (ServiceType) String

func (s ServiceType) String() string

type Status

type Status int

const (
	StatusInit Status = iota
	StatusOpen
	StatusOpenSuccess
	StatusReady
	StatusZkConnected
	StatusStopping
	StatusStopped
)

type ZKError

type ZKError struct {
	Msg string
	Err error
}

func (*ZKError) Error

func (z *ZKError) Error() string

func (*ZKError) Unwrap

func (z *ZKError) Unwrap() error