sqs

package
v0.0.0-...-db5d468 Latest Latest
Warning

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

Go to latest
Published: Nov 29, 2023 License: BSD-2-Clause Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ECSManager

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

func NewECSManager

func NewECSManager(cluster, service string) *ECSManager

func (*ECSManager) Beta

func (m *ECSManager) Beta() (uint, error)

func (*ECSManager) SetB

func (m *ECSManager) SetB() chan float64

func (*ECSManager) SetLimits

func (m *ECSManager) SetLimits(min, max int64)

type SQSControlManager

type SQSControlManager interface {
	SetB() chan float64
	Beta() (uint, error)
}

Whatever's implementing the control, likely an ECS Manager.

type SQSManager

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

Implements the control.Manager interface

func NewSQSManager

func NewSQSManager(queue string, updatePeriod time.Duration, control SQSControlManager) *SQSManager

func (*SQSManager) Beta

func (m *SQSManager) Beta() uint

func (*SQSManager) DXY

func (m *SQSManager) DXY(unit time.Duration) (float64, float64)

func (*SQSManager) MuP

func (m *SQSManager) MuP() (float64, bool)

func (*SQSManager) Q

func (m *SQSManager) Q() uint

func (*SQSManager) SetB

func (m *SQSManager) SetB() chan float64

func (*SQSManager) XmY

func (m *SQSManager) XmY() uint

Jump to

Keyboard shortcuts

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