arenaredis

Documentation

Index

• func NewBackend(keyPrefix string, client rueidis.Client) arena.Backend
• func NewFrontend(keyPrefix string, client rueidis.Client, opts ...RedisFrontendOption) arena.Frontend
• type ContainerCapacity
• type Metrics
  • func NewMetrics(keyPrefix string, client rueidis.Client) *Metrics
  • func (m *Metrics) GetContainerCount(ctx context.Context, fleetName string) (int, error)
  • func (m *Metrics) GetContainers(ctx context.Context, fleetName string) ([]ContainerCapacity, error)
• type RedisFrontendOption
  • func WithCandidateContainerMaxCount(count int) RedisFrontendOption

Functions

func NewBackend

func NewBackend(keyPrefix string, client rueidis.Client) arena.Backend

func NewFrontend

func NewFrontend(keyPrefix string, client rueidis.Client, opts ...RedisFrontendOption) arena.Frontend

Types

type ContainerCapacity

type ContainerCapacity struct {
	ContainerID string
	Capacity    int
}

type Metrics

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

func NewMetrics

func NewMetrics(keyPrefix string, client rueidis.Client) *Metrics

func (*Metrics) GetContainerCount

func (m *Metrics) GetContainerCount(ctx context.Context, fleetName string) (int, error)

func (*Metrics) GetContainers

func (m *Metrics) GetContainers(ctx context.Context, fleetName string) ([]ContainerCapacity, error)

type RedisFrontendOption

type RedisFrontendOption interface {
	// contains filtered or unexported methods
}

func WithCandidateContainerMaxCount

func WithCandidateContainerMaxCount(count int) RedisFrontendOption