distributed

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 5, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewLocalDistributedService

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

NewLocalDistributedService 初始化本地分布式服务

Types

type LocalDistributedProvider

type LocalDistributedProvider struct {
}

LocalDistributedProvider 提供App的具体实现方法

func (*LocalDistributedProvider) Boot

Boot 启动调用

func (*LocalDistributedProvider) IsDefer

func (h *LocalDistributedProvider) IsDefer() bool

IsDefer 是否延迟初始化

func (*LocalDistributedProvider) Name

func (h *LocalDistributedProvider) Name() string

Name 获取字符串凭证

func (*LocalDistributedProvider) Params

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

Params 获取初始化参数

func (*LocalDistributedProvider) Register

Register 注册StartApp方法

type LocalDistributedService

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

LocalDistributedService 代表Start框架的App实现

func (LocalDistributedService) Select

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

Select 为分布式选择器

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL