distributed

Documentation

Index

• func NewLocalDistrubutedService(params ...interface{}) (interface{}, error)
• type LocalDistributedProvider
  • func (sp *LocalDistributedProvider) Boot(container framework.Container) error
  • func (sp *LocalDistributedProvider) IsDefer() bool
  • func (sp *LocalDistributedProvider) Name() string
  • func (sp *LocalDistributedProvider) Params(container framework.Container) []interface{}
  • func (sp *LocalDistributedProvider) Register(container framework.Container) framework.NewInstance
• type LocalDistributedService
  • func (s LocalDistributedService) Select(serviceName string, appId string, holdTime time.Duration) (selectAppId string, err error)

Functions

func NewLocalDistrubutedService

func NewLocalDistrubutedService(params ...interface{}) (interface{}, error)

Types

type LocalDistributedProvider

type LocalDistributedProvider struct {
}

LocalDistributedProvider 提供App的具体实现方法

func (*LocalDistributedProvider) Boot

func (sp *LocalDistributedProvider) Boot(container framework.Container) error

Boot 启动调用

func (*LocalDistributedProvider) IsDefer

func (sp *LocalDistributedProvider) IsDefer() bool

IsDefer 是否延迟初始化

func (*LocalDistributedProvider) Name

func (sp *LocalDistributedProvider) Name() string

Name 获取字符串凭证

func (*LocalDistributedProvider) Params

func (sp *LocalDistributedProvider) Params(container framework.Container) []interface{}

Params 获取初始化参数

func (*LocalDistributedProvider) Register

func (sp *LocalDistributedProvider) Register(container framework.Container) framework.NewInstance

Register 注册HadeApp方法

type LocalDistributedService

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

func (LocalDistributedService) Select

func (s LocalDistributedService) Select(serviceName string, appId string, holdTime time.Duration) (selectAppId string, err error)

Select 为分布式选择器