cluster

type ChannelCoordinator interface {
	Start(ctx context.Context) error
	Stop()
	GetPeers() []PeerInfo
	InstanceID() string
	IsLeader() bool
	AcquireChannel(ctx context.Context, channelID string) (bool, error)
	RenewChannelLease(ctx context.Context, channelID string) error
	ReleaseChannel(ctx context.Context, channelID string) error
	OwnedChannels() []string
	ShouldAcquireChannel(channelID string, tags []string) bool
}

type ChannelHealth struct {
	Running int `json:"running"`
	Stopped int `json:"stopped"`
	Errored int `json:"errored"`
}

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

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

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

type HealthResponse struct {
	Status   HealthStatus  `json:"status"`
	Channels ChannelHealth `json:"channels"`
	Uptime   string        `json:"uptime"`
}

type HealthStatus string

type MessageDeduplicator interface {
	IsDuplicate(key string) bool
}

type PeerInfo struct {
	InstanceID string    `json:"instance_id"`
	LastSeen   time.Time `json:"last_seen"`
	Channels   []string  `json:"channels"`
	Status     string    `json:"status"`
}

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

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

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