agent

package

v18.6.0-rc1 Latest Latest Go to latest Published: Oct 15, 2025 License: MIT Imports: 8 Imported by: 0

Documentation ¶

Index ¶

Constants
type Factory
- func (f *Factory) IsProducingLeaderModules() bool
- func (f *Factory) Name() string
type Module

Constants ¶

const (
	RegisterInitBackoff   = 10 * time.Second
	RegisterMaxBackoff    = 5 * time.Minute
	RegisterResetDuration = 10 * time.Minute
	RegisterBackoffFactor = 2.0
	RegisterJitter        = 5.0
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Factory ¶

type Factory struct {
}

func (*Factory) IsProducingLeaderModules ¶

func (f *Factory) IsProducingLeaderModules() bool

func (*Factory) Name ¶

func (f *Factory) Name() string

type Module ¶ added in v18.1.0

type Module[CM any] struct {
	Log               *slog.Logger
	PollConfig        retry.PollConfigFactory
	Client            rpc.AgentRegistrarClient
	RegisterRequest   func() *rpc.RegisterRequest
	UnregisterRequest func() *rpc.UnregisterRequest
}

func (*Module[CM]) DefaultAndValidateConfiguration ¶ added in v18.1.0

func (m *Module[CM]) DefaultAndValidateConfiguration(config CM) error

func (*Module[CM]) Name ¶ added in v18.1.0

func (m *Module[CM]) Name() string

func (*Module[CM]) Run ¶ added in v18.1.0

func (m *Module[CM]) Run(ctx context.Context, cfg <-chan CM) error

Source Files ¶

View all Source files

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