service

Documentation

Index

• Constants
• Variables
• type Config
  • func NewConfig() *Config
  • func (c Config) GetID() int
  • func (c Config) GetPutPayloadSec() time.Duration
  • func (c *Config) SetID(id int)
  • func (c *Config) SetPutPayloadSec(putPayloadSec time.Duration)
  • func (c *Config) TidyAndCheck() error
• type FactoryManager
  • func NewFactoryManager() *FactoryManager
  • func (mgr *FactoryManager) MustRegister(name string, producer Producer)
  • func (mgr *FactoryManager) Produce(name string) (export.IService, error)
• type Group
  • func NewGroup(name string) *Group
  • func (sg *Group) AddInfo(serviceID int, info *Info)
  • func (sg *Group) EachConfig(f func(export.IConfig) bool)
  • func (sg *Group) EachInfo(f func(int, *Info) bool)
  • func (sg *Group) EachInstance(f func(string, int, *Instance) bool)
  • func (sg *Group) EachPayload(f func(string, int, int) bool)
  • func (sg *Group) GetConfigByID(serviceID int) export.IConfig
  • func (sg *Group) GetInfoByID(serviceID int) *Info
  • func (sg *Group) GetInstance(serviceID int) *Instance
  • func (sg *Group) GetPayloadByID(serviceID int) int
  • func (sg *Group) RemoveInfo(serviceID int)
  • func (sg *Group) RoundRobinPickInstance() *Info
• type Info
  • func NewInfo(config export.IConfig, configData []byte, id int) *Info
  • func (i Info) IsEmpty() bool
• type Instance
  • func NewInstance() (i *Instance)
  • func (i Instance) IsEmpty() bool
  • func (i Instance) String() string
• type Producer

Constants

const GlobalConfigServiceID = "global"

const (
	PayloadNil = -1
)

Variables

var ErrDuplicateFactory = errors.New("duplicate factory")

var ErrProducerIsNil = errors.New("producer is nil")

var ErrUnsupportedService = errors.New("unsupported service")

var FM = NewFactoryManager()

//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

Types

type Config

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

func NewConfig

func NewConfig() *Config

func (Config) GetID

func (c Config) GetID() int

func (Config) GetPutPayloadSec

func (c Config) GetPutPayloadSec() time.Duration

func (*Config) SetID

func (c *Config) SetID(id int)

func (*Config) SetPutPayloadSec

func (c *Config) SetPutPayloadSec(putPayloadSec time.Duration)

func (*Config) TidyAndCheck

func (c *Config) TidyAndCheck() error

type FactoryManager

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

//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

func NewFactoryManager

func NewFactoryManager() *FactoryManager

func (*FactoryManager) MustRegister

func (mgr *FactoryManager) MustRegister(name string, producer Producer)

func (*FactoryManager) Produce

func (mgr *FactoryManager) Produce(name string) (export.IService, error)

type Group

type Group struct {
	Name string

	GlobalConfigReflectType reflect.Type
	ConfigReflectType       reflect.Type

	GlobalConfig     export.IConfig
	GlobalConfigData []byte
	Infos            *linkedhashmap.Map
	// contains filtered or unexported fields
}

func NewGroup

func NewGroup(name string) *Group

func (*Group) AddInfo

func (sg *Group) AddInfo(serviceID int, info *Info)

func (*Group) EachConfig

func (sg *Group) EachConfig(f func(export.IConfig) bool)

func (*Group) EachInfo

func (sg *Group) EachInfo(f func(int, *Info) bool)

func (*Group) EachInstance

func (sg *Group) EachInstance(f func(string, int, *Instance) bool)

func (*Group) EachPayload

func (sg *Group) EachPayload(f func(string, int, int) bool)

func (*Group) GetConfigByID

func (sg *Group) GetConfigByID(serviceID int) export.IConfig

func (*Group) GetInfoByID

func (sg *Group) GetInfoByID(serviceID int) *Info

func (*Group) GetInstance

func (sg *Group) GetInstance(serviceID int) *Instance

func (*Group) GetPayloadByID

func (sg *Group) GetPayloadByID(serviceID int) int

func (*Group) RemoveInfo

func (sg *Group) RemoveInfo(serviceID int)

func (*Group) RoundRobinPickInstance

func (sg *Group) RoundRobinPickInstance() *Info

type Info

type Info struct {
	Config     export.IConfig
	ConfigData []byte
	Instance   *Instance
	Payload    int
}

//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

func NewInfo

func NewInfo(config export.IConfig, configData []byte, id int) *Info

func (Info) IsEmpty

func (i Info) IsEmpty() bool

type Instance

type Instance struct {
	PID       *actor.PID
	PprofAddr string
	Extra     map[string]interface{}
}

//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

func NewInstance

func NewInstance() (i *Instance)

func (Instance) IsEmpty

func (i Instance) IsEmpty() bool

func (Instance) String

func (i Instance) String() string

type Producer

type Producer = func() export.IService