Versions in this module Expand all Collapse all v0 v0.4.0 Jul 13, 2026 v0.3.0 Jul 8, 2026 Changes in this version type ClusterConfig + DiscoveryHTTPHost string + DiscoveryKind string + DiscoveryYMLPath string + type DiscoveryKind uint8 + const DiscoveryKindHttp + const DiscoveryKindStatic + func ParseDiscoveryKind(s string) (DiscoveryKind, error) + func (d DiscoveryKind) String() string v0.2.0 Jul 1, 2026 Changes in this version type PartitionConfig + MaxBackoffSec int64 v0.1.0 Jun 28, 2026 Changes in this version + const DefaultDLQMaxSizeBytes + const DefaultRaftElectionTick + const DefaultRaftHeartbeatTick + const DefaultRaftTickMs + var CfgFile string + var ErrDeadlineExceeded = errors.New("deadline exceeded") + var ErrDuplicateJobID = errors.New("job ID already exist") + var ErrInvalidPayload = errors.New("invalid payload") + var ErrInvalidRaftMessage = errors.New("invalid raft message") + var ErrMaxRetriesExceeded = errors.New("max retries exceeded") + var ErrQueueFull = errors.New("queue is full") + var ErrServiceUnavailable = errors.New("service unavailable: node is not active") + var ErrTopicExists = errors.New("topic already exists") + var ErrTopicNotFound = errors.New("topic not found") + var ErrUnknownCommand = errors.New("unknown command type") + var ErrUnknownNodeID = errors.New("unknown node ID for raft ID") + var ErrUnknownRequestType = errors.New("unknown request type") + type ApiConfig struct + ApiPort uint16 + ListenAddr string + TimeoutSeconds int + TokenPath string + type ClusterConfig struct + CACertPath string + CertPath string + DLQMaxSizeBytes int64 + InitialVoters []string + KeyPath string + ListenAddr string + Peers []string + QUICPort uint16 + RaftElectionTick int + RaftHeartbeatTick int + RaftTickMs int + SnapshotIntervalSec uint64 + SnapshotTriggerCount uint64 + WALFlushThreshold int + type ClusterMetrics struct + func GetClusterMetrics() *ClusterMetrics + func (m *ClusterMetrics) AddBytesReceived(bytes uint64) + func (m *ClusterMetrics) AddBytesSent(bytes uint64) + func (m *ClusterMetrics) ConnectionAccepted() + func (m *ClusterMetrics) ConnectionDropped() + func (m *ClusterMetrics) ConnectionError() + func (m *ClusterMetrics) ConnectionOpened() + func (m *ClusterMetrics) ConnectionRejected() + func (m *ClusterMetrics) LeaderChanged() + func (m *ClusterMetrics) MessageReceived() + func (m *ClusterMetrics) MessageSent() + func (m *ClusterMetrics) ReceiveError() + func (m *ClusterMetrics) SendError() + func (m *ClusterMetrics) SetLastAppliedWalIndex(index uint64) + func (m *ClusterMetrics) WalFlush() + type Config struct + AddressResolver ResolverConfig + ApiConfig ApiConfig + Cluster ClusterConfig + DataDir string + Logging LoggingConfig + NodeID string + Partition PartitionConfig + Proxy ProxyConfig + TLSVerifier VerifierConfig + WAL WALConfig + func LoadConfig() (*Config, error) + func NewConfig() *Config + func (c *Config) GetClusterAddr() string + func (c *Config) GetProxyAddr() string + func (c *Config) Validate() error + type GatewayMetrics struct + func GetGatewayMetrics() *GatewayMetrics + func (m *GatewayMetrics) ConnectionClosed() + func (m *GatewayMetrics) ConnectionFailed() + func (m *GatewayMetrics) ConnectionOpened() + func (m *GatewayMetrics) MessageReceived() + func (m *GatewayMetrics) MessageSent() + func (m *GatewayMetrics) NetworkError() + func (m *GatewayMetrics) ProxyConnected() + func (m *GatewayMetrics) ProxyDisconnected() + type LoggingConfig struct + Format string + Level string + OutputPath string + type PartitionConfig struct + ActiveQueueCapacity int + DLQMaxAgeMs int64 + DLQMaxBytes int64 + DispatchBatchSize int + HeartbeatTickMs int + MaxBackoffMs int64 + MaxRetries int + PartitionTickMs int + ProxyCleanupTickSec int + RetryBaseDelayMs int64 + type PartitionMetrics struct + func GetPartitionMetrics() *PartitionMetrics + func (m *PartitionMetrics) JobAdded(topic string, n uint64) + func (m *PartitionMetrics) JobCompleted(topic string, n uint64) + func (m *PartitionMetrics) JobDLQ(topic string, n uint64) + func (m *PartitionMetrics) JobRetried(topic string, n uint64) + func (m *PartitionMetrics) RemoveTopic(topic string) + func (m *PartitionMetrics) SetActiveDepth(topic string, v uint32) + type ProxyConfig struct + Addr string + CAPath string + CertPath string + KeyPath string + Port int + type ResolverConfig struct + Config map[string]any + Type string + type TopicManagerMetrics struct + func GetTopicManagerMetrics() *TopicManagerMetrics + func (m *TopicManagerMetrics) SetActiveTopics(count int) + func (m *TopicManagerMetrics) TopicCreated() + func (m *TopicManagerMetrics) TopicRemoved() + type VerifierConfig struct + Config map[string]any + Type string + type WALConfig struct + CompactAfterBytes int64 + SyncInterval string
Go to main page