workflows

Documentation

Index

• Constants
• func NewGatewayDiscoveryWorkflow(gatewaysCounter DiscoveredGatewaysCounter) (telemetry.Workflow, error)
• type DiscoveredGatewaysCountProvider
  • func NewDiscoveredGatewaysCountProvider(counter DiscoveredGatewaysCounter) (*DiscoveredGatewaysCountProvider, error)
  • func (d *DiscoveredGatewaysCountProvider) Kind() provider.Kind
  • func (d *DiscoveredGatewaysCountProvider) Name() string
  • func (d *DiscoveredGatewaysCountProvider) Provide(context.Context) (types.ProviderReport, error)
• type DiscoveredGatewaysCounter

Constants

const (
	DiscoveredGatewaysCountProviderName = "discovered_gateways_count"
	DiscoveredGatewaysCountProviderKind = provider.Kind(DiscoveredGatewaysCountProviderName)
	DiscoveredGatewaysCountKey          = types.ProviderReportKey(DiscoveredGatewaysCountProviderName)
)

const GatewayDiscoveryWorkflowName = "gateway_discovery"

Functions

func NewGatewayDiscoveryWorkflow

func NewGatewayDiscoveryWorkflow(gatewaysCounter DiscoveredGatewaysCounter) (telemetry.Workflow, error)

Types

type DiscoveredGatewaysCountProvider

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

DiscoveredGatewaysCountProvider is a provider that reports the number of currently discovered Gateways.

func NewDiscoveredGatewaysCountProvider

func NewDiscoveredGatewaysCountProvider(counter DiscoveredGatewaysCounter) (*DiscoveredGatewaysCountProvider, error)

func (*DiscoveredGatewaysCountProvider) Kind

func (d *DiscoveredGatewaysCountProvider) Kind() provider.Kind

func (*DiscoveredGatewaysCountProvider) Name

func (d *DiscoveredGatewaysCountProvider) Name() string

func (*DiscoveredGatewaysCountProvider) Provide

func (d *DiscoveredGatewaysCountProvider) Provide(context.Context) (types.ProviderReport, error)

type DiscoveredGatewaysCounter

type DiscoveredGatewaysCounter interface {
	GatewayClientsCount() int
}

DiscoveredGatewaysCounter is an interface that allows to count currently discovered Gateways.