Versions in this module Expand all Collapse all v1 v1.0.1 Nov 22, 2025 Changes in this version + func SetDefaultManager(manager *Manager) + func WithHealthCheck(parent context.Context) (context.Context, context.CancelFunc) + func WithRaftProposal(parent context.Context) (context.Context, context.CancelFunc) + func WithRequest(parent context.Context) (context.Context, context.CancelFunc) + type Config struct + BrokerHeartbeat time.Duration + ConnectionTimeout time.Duration + ForceShutdown time.Duration + GracefulShutdown time.Duration + HealthCheck time.Duration + IdleTimeout time.Duration + LeaderElection time.Duration + MetadataSync time.Duration + MetadataUpdate time.Duration + RaftElection time.Duration + RaftHeartbeat time.Duration + RaftProposal time.Duration + RaftSnapshot time.Duration + ReadinessCheck time.Duration + RebalanceTimeout time.Duration + RequestTimeout time.Duration + func DefaultConfig() *Config + func ProductionConfig() *Config + func TestConfig() *Config + func (c *Config) Validate() error + type Manager struct + func Default() *Manager + func NewManager(config *Config) (*Manager, error) + func (m *Manager) GetConfig() *Config + func (m *Manager) UpdateConfig(config *Config) error + func (m *Manager) WithConnection(parent context.Context) (context.Context, context.CancelFunc) + func (m *Manager) WithCustom(parent context.Context, duration time.Duration) (context.Context, context.CancelFunc) + func (m *Manager) WithGracefulShutdown(parent context.Context) (context.Context, context.CancelFunc) + func (m *Manager) WithHealthCheck(parent context.Context) (context.Context, context.CancelFunc) + func (m *Manager) WithMetadataSync(parent context.Context) (context.Context, context.CancelFunc) + func (m *Manager) WithMetadataUpdate(parent context.Context) (context.Context, context.CancelFunc) + func (m *Manager) WithRaftElection(parent context.Context) (context.Context, context.CancelFunc) + func (m *Manager) WithRaftProposal(parent context.Context) (context.Context, context.CancelFunc) + func (m *Manager) WithReadinessCheck(parent context.Context) (context.Context, context.CancelFunc) + func (m *Manager) WithRebalance(parent context.Context) (context.Context, context.CancelFunc) + func (m *Manager) WithRequest(parent context.Context) (context.Context, context.CancelFunc) + type Operation struct + func NewOperation(name string, timeout time.Duration) *Operation + func (o *Operation) Execute(parent context.Context, fn func(ctx context.Context) error) error + func (o *Operation) ExecuteWithRetry(parent context.Context, maxRetries int, fn func(ctx context.Context) error) error
Go to main page