applications

Documentation

Index

• Variables
• func RunApplicationCollector(ctx context.Context, ms *switcher.MessageSwitcher, argo *argo.Client) error
• type ApplicationMessageCollector
  • func (c *ApplicationMessageCollector) Run(ctx context.Context) error

Variables

var DefaultBackoff = wait.Backoff{
	Steps:    math.MaxInt32,
	Duration: 5 * time.Second,
	Factor:   2,
	Jitter:   0.1,
	Cap:      30 * time.Second,
}

Functions

func RunApplicationCollector

func RunApplicationCollector(ctx context.Context, ms *switcher.MessageSwitcher, argo *argo.Client) error

Types

type ApplicationMessageCollector

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

func (*ApplicationMessageCollector) Run

func (c *ApplicationMessageCollector) Run(ctx context.Context) error