registry

type MemoryRegistry ¶ added in v0.0.3

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

MemoryRegistry is a concurrent in-memory implementation of WorkerRegistry.

func NewMemoryRegistry() *MemoryRegistry

func (r *MemoryRegistry) Delete(workerID string)

func (r *MemoryRegistry) Get(workerID string) (string, bool)

func (r *MemoryRegistry) Set(workerID, addr string)

type RedisRegistry ¶ added in v0.0.3

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

RedisRegistry implements WorkerRegistry using simple Redis strings.

Key schema:

{prefix}registry:{workerID}  ->  string "host:port"

Each key has a TTL equal to registryTTL. The health poller refreshes the TTL on every successful check by calling Set again.

func NewRedisRegistry(client *redisstate.Client, registryTTL time.Duration) *RedisRegistry

func (r *RedisRegistry) Delete(workerID string)

func (r *RedisRegistry) Get(workerID string) (string, bool)

func (r *RedisRegistry) Set(workerID, addr string)

type WorkerRegistry ¶ added in v0.0.3

type WorkerRegistry interface {
	Get(workerID string) (string, bool)
	Set(workerID string, addr string)
	Delete(workerID string)
}

WorkerRegistry defines the contract for worker address lookup. MemoryRegistry is the in-process implementation; Redis implements the same interface for shared state during rolling updates.