distributed

Documentation

Index

• func NewLocalDistributedService(params ...any) (any, error)
• type LocalDistributedProvider
  • func (provider *LocalDistributedProvider) Boot(container framework.Container) error
  • func (provider *LocalDistributedProvider) IsDefer() bool
  • func (provider *LocalDistributedProvider) Name() string
  • func (provider *LocalDistributedProvider) Params(container framework.Container) []any
  • func (provider *LocalDistributedProvider) Register(container framework.Container) framework.NewInstance
• type LocalDistributedService
  • func (service LocalDistributedService) Select(serviceName, appID string, holdTime time.Duration) (string, error)

Functions

func NewLocalDistributedService

func NewLocalDistributedService(params ...any) (any, error)

Types

type LocalDistributedProvider

type LocalDistributedProvider struct {
}

func (*LocalDistributedProvider) Boot

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

func (*LocalDistributedProvider) IsDefer

func (provider *LocalDistributedProvider) IsDefer() bool

func (*LocalDistributedProvider) Name

func (provider *LocalDistributedProvider) Name() string

func (*LocalDistributedProvider) Params

func (provider *LocalDistributedProvider) Params(container framework.Container) []any

func (*LocalDistributedProvider) Register

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

type LocalDistributedService

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

func (LocalDistributedService) Select

func (service LocalDistributedService) Select(serviceName, appID string, holdTime time.Duration) (string, error)