meter

package

v1.4.4 Latest Latest Go to latest Published: Aug 26, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Package meter provides a scalable worker Group implementing service.Service and service.Scalable.

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	Enabled   bool
	Interval  time.Duration
	Instances int
}

Config configures the worker group.

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

Group is a scalable worker set.

func New(name string, cfg Config) *Group

func (g *Group) Instances() int

func (g *Group) IsActive() bool

func (g *Group) Launch(ctx context.Context) error

func (g *Group) Logs() <-chan service.ServiceLog

func (g *Group) Metrics() service.Metrics

func (g *Group) Off()

func (g *Group) On()

func (g *Group) Reload(ctx context.Context, cfg any) error

func (g *Group) ScaleTo(n int) error

Scalable

func (g *Group) Stop(ctx context.Context) error