distributed

package

v1.0.0 Latest Latest Go to latest Published: Dec 27, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

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

NewLocalDistributedService 初始化本地分布式服务

type LocalDistributedProvider struct {
}

LocalDistributedProvider 提供App的具体实现方法

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

Boot 启动调用

func (h *LocalDistributedProvider) IsDefer() bool

IsDefer 是否延迟初始化

func (h *LocalDistributedProvider) Name() string

Name 获取字符串凭证

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

Params 获取初始化参数

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

Register 注册PBApp方法

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

LocalDistributedService 代表PB框架的App实现

func (s LocalDistributedService) Select(serviceName, appID string,
	holdTime time.Duration) (selectAppID string, err error)

Select 为分布式选择器