providerwithmetrics

package
v0.5.0 Latest Latest
Warning

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

Go to latest
Published: Mar 11, 2021 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Entity

type Entity interface {
	provider.Entity
	GetMetrics(prefix string) stats.MapMetricsOptions
	GetAliveHandlers(prefix string) stats.MapCheckFunc
	GetReadyHandlers(prefix string) stats.MapCheckFunc
}

type Provider

type Provider struct {
	Entitys provider.MapEnity
	*provider.Provider
}

Provider provides abstract worker.

func NewProvider

func NewProvider(ctx context.Context, providersName, providerName string) *Provider

NewProvider creates provider

func (*Provider) GetAliveHandlers

func (bp *Provider) GetAliveHandlers(prefix string) stats.MapCheckFunc

GetAliveHandlers return array of the aliveHandlers from provider

func (*Provider) GetMetrics

func (bp *Provider) GetMetrics(prefix string) stats.MapMetricsOptions

GetMetrics return map of the metrics from provider

func (*Provider) GetReadyHandlers

func (bp *Provider) GetReadyHandlers(prefix string) stats.MapCheckFunc

GetReadyHandlers return array of the readyHandlers from provider

func (*Provider) Shutdown added in v0.2.0

func (bp *Provider) Shutdown() error

Shutdown should shutdown all known entitys.

func (*Provider) ShutdownEnity added in v0.2.0

func (bp *Provider) ShutdownEnity(enityName string) error

ShutdownEnity starts connection things like watchers and queues.

func (*Provider) Start added in v0.2.0

func (bp *Provider) Start() error

Start starts all known entitys.

func (*Provider) StartEnity added in v0.2.0

func (bp *Provider) StartEnity(enityName string) error

StartEnity starts connection things like watchers and queues.

Jump to

Keyboard shortcuts

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