service_manager

Dec 10, 2019

Changes in this version

type Logger

+ Error func(args ...interface{})

type Status

+ const StatusReady

+ const StatusZkConnected

Dec 6, 2019

Changes in this version

+ func GetCurrentPath() (string, error)

type NodeInfo

+ ExecPath string

Dec 6, 2019

Changes in this version

+ var ErrHost = errors.New("host error")

+ var ErrSingletonServiceIsRunning = errors.New("service type is singleton and there is one already running")

+ func GRpcConnTest() pool.ConnTestFunc

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

+ func GRpcFactory() ConnFactory

type Consumer

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

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

+ type ConsumerOption interface

+ type ConsumerOptionConnFactory ConnFactory

+ type ConsumerOptionConnMax int

+ type ConsumerOptionConnMin int

+ type ConsumerOptionConnTestFunc pool.ConnTestFunc

type Manager

+ func (m *Manager) Close() error

+ func (m *Manager) NewConsumer(service *Service, options ...ConsumerOption) *Consumer

+ 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 struct

+ Host string

+ HostName string

+ Pid int

+ Port int

+ type NodeRunningError struct

+ Err error

+ RunningHost string

+ func (e *NodeRunningError) Error() string

+ func (e *NodeRunningError) Unwrap() error

+ type OptionHost string

+ type Producer struct

+ func (p *Producer) Close() error

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

+ func (p *Producer) Status() Status

+ type ProducerOption interface

+ type Protocol int

+ const ProtocolGRPC

+ const ProtocolHttp

+ const ProtocolThrift

+ func (p Protocol) String() string

type Service

+ Path string

+ Protocol Protocol

+ Type ServiceType

+ type ServiceOption interface

+ type ServiceOptionProtocol Protocol

+ type ServiceOptionServiceType ServiceType

+ type ServiceType int

+ const ServiceTypeNormal

+ const ServiceTypeSingleton

+ func (s ServiceType) String() string

+ type Status int

+ const StatusInit

+ const StatusOpen

+ const StatusOpenSuccess

+ const StatusRegistered

+ const StatusStopped

+ const StatusStopping

+ type ZKError struct

+ Err error

+ Msg string

+ func (z *ZKError) Error() string

+ func (z *ZKError) Unwrap() error

Oct 14, 2019

Changes in this version

+ type Logger interface

+ Debug func(msg string)

+ Info func(msg string)

+ Panic func(msg string)

+ Warn func(msg string)

type Service

+ func (s *Service) SetLogger(logger Logger)

Oct 8, 2019

Changes in this version

+ var ErrConnectToZooKeeper = zk.ErrNoServer

+ var ErrInvalidPath = zk.ErrInvalidPath

type Consumer

+ func (c *Consumer) Close()

+ func (c *Consumer) Run()

Oct 8, 2019

Changes in this version

+ var ErrNoService = errors.New("no service")

+ var ErrNoServiceAlive = errors.New("no service alive")

+ type Consumer struct

+ func NewConsumer(path string, zkHosts []string) *Consumer

+ func (c *Consumer) GetServerList() (list []string, err error)

+ func (c *Consumer) GetServiceHost() (host string, err error)

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

+ type Data struct

+ Host string

+ HostName string

+ Pid int

+ type Manager struct

+ func NewManager(hosts []string) *Manager

Oct 8, 2019

Changes in this version

+ type Service struct

+ func NewService(path string, hosts []string) *Service

+ func (s *Service) Open() (err error)

+ func (s Service) Close()