lib

Documentation

Index

• type Config
  • func NewConfig(filePath string) (*Config, error)
• type DispatchOptions
• type Dispatcher
  • func NewDispatcher(opts *DispatchOptions) *Dispatcher
  • func (d *Dispatcher) Poll() error
• type Metric
  • func MetricsFromServices(cluster *string, services []*ecs.Service) []*Metric
• type Worker

Types

type Config

type Config struct {
	Accounts []*account `json:"accounts"`
}

func NewConfig

func NewConfig(filePath string) (*Config, error)

type DispatchOptions

type DispatchOptions struct {
	Config    *Config
	Ctx       context.Context
	Interval  time.Duration
	Namespace string
}

type Dispatcher

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

func NewDispatcher

func NewDispatcher(opts *DispatchOptions) *Dispatcher

func (*Dispatcher) Poll

func (d *Dispatcher) Poll() error

type Metric

type Metric struct {
	Cluster      *string
	ServiceName  *string
	DesiredCount *int64
	PendingCount *int64
	RunningCount *int64
}

func MetricsFromServices

func MetricsFromServices(cluster *string, services []*ecs.Service) []*Metric

type Worker

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