proxy

type Config[S ServerConfig] struct {
	Servers []S
	Route   Route
}

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

type MemcacheOption func(conf *memcacheConfig)

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

type ReplicatedRouteOption func(conf *replicatedRouteConfig)

type Route interface {
	// NewSelector ...
	NewSelector() Selector

	// AllServerIDs returns list of all possible server ids
	AllServerIDs() []ServerID
}

type Selector interface {
	// SetFailedServer ...
	SetFailedServer(server ServerID)

	// HasNextAvailableServer check if next available server ready to be fallback to
	HasNextAvailableServer() bool

	// SelectServer choose a server id, will keep in this server id unless Reset is call or failed server added
	SelectServer(key string) ServerID

	// SelectForDelete choose servers for deleting
	SelectForDelete(key string) []ServerID

	// Reset the selection
	Reset()
}

type ServerConfig interface {
	// GetID returns the server id, must be unique
	GetID() ServerID
}

type ServerID int

type ServerStats interface {
	// IsServerFailed check whether the server is currently not connected
	IsServerFailed(server ServerID) bool

	// NotifyServerFailed ...
	NotifyServerFailed(server ServerID)

	// GetMemUsage returns memory usage in bytes
	GetMemUsage(server ServerID) float64
}

type SimpleServerConfig struct {
	ID   ServerID
	Host string
	Port uint16
}

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

type SimpleStatsOption func(conf *simpleStatsConfig)

type StatsClient interface {
	// GetMemUsage get memory usage in bytes
	GetMemUsage() (uint64, error)

	// Close client
	Close() error
}