redis_util

package

v0.0.0-...-2e1a402 Latest Latest Go to latest Published: Dec 22, 2021 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/PenguinCats/Unison-Elastic-Compute

Links

Open Source Insights

README ¶

UEC Redis 数据结构

container

uec:container:{container_ID}:busy
- type: string
- 存在则表示繁忙
uec:container:{container_ID}:slave_ID
- type: string
uec:container:{container_ID}:profile.dict
- type: hash
- hash fields
  - ext_container_id
  - image_name
  - core_request
  - memory_request
  - storage_request
uec:container:{container_ID}:profile.exposed_tcp_ports
- type: list
uec:container:{container_ID}:profile.exposed_tcp_mapping_ports
- type: list
uec:container:{container_ID}:profile.exposed_udp_ports
- type: list
uec:container:{container_ID}:profile.exposed_udp_mapping_ports
- type: list
uec:container:{container_ID}:status
- type: hash
- hash fields
  - status
  - cpu_percent
  - memory_percent
  - memory_size
  - storage_size
  - storage_percent

Documentation ¶

Index ¶

type RedisDAO
- func New(host, port, password, db string) (*RedisDAO, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type RedisDAO ¶

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

func New ¶

func New(host, port, password, db string) (*RedisDAO, error)

func (*RedisDAO) ContainerDelAll ¶

func (t *RedisDAO) ContainerDelAll(containerID string)

func (*RedisDAO) ContainerHSet ¶

func (t *RedisDAO) ContainerHSet(containerID, key, field string, value interface{}) error

func (*RedisDAO) ContainerHSetWithTime ¶

func (t *RedisDAO) ContainerHSetWithTime(containerID, key, field string, value interface{}, second int) error

func (*RedisDAO) ContainerReleaseBusy ¶

func (t *RedisDAO) ContainerReleaseBusy(containerID string)

func (*RedisDAO) ContainerResetProfile ¶

func (t *RedisDAO) ContainerResetProfile(containerID string, profile container.ContainerProfile) error

func (*RedisDAO) ContainerSet ¶

func (t *RedisDAO) ContainerSet(containerID, key string, value interface{}) error

func (*RedisDAO) ContainerSetBusy ¶

func (t *RedisDAO) ContainerSetBusy(containerID string) bool

func (*RedisDAO) ContainerSetWithTime ¶

func (t *RedisDAO) ContainerSetWithTime(slaveID, containerID, key string, value interface{}, seconds int) error

func (*RedisDAO) ContainerUpdateStats ¶

func (t *RedisDAO) ContainerUpdateStats(containerID string, stats container.Stats) error

func (*RedisDAO) ContainerUpdateStatus ¶

func (t *RedisDAO) ContainerUpdateStatus(containerID string, status container.ContainerStatus) error

func (*RedisDAO) Reset ¶

func (t *RedisDAO) Reset() error

func (*RedisDAO) SlaveDelete ¶

func (t *RedisDAO) SlaveDelete(slaveID string) error

func (*RedisDAO) SlaveGetAddToken ¶

func (t *RedisDAO) SlaveGetAddToken() (string, error)

func (*RedisDAO) SlaveGetImageList ¶

func (t *RedisDAO) SlaveGetImageList(slaveID string) ([]types.ImageListItem, error)

func (*RedisDAO) SlaveProfile ¶

func (t *RedisDAO) SlaveProfile(slaveID string) (map[string]string, error)

func (*RedisDAO) SlaveResetHostInfo ¶

func (t *RedisDAO) SlaveResetHostInfo(slaveID string, hostInfo hosts.HostInfo) error

func (*RedisDAO) SlaveResetImageList ¶

func (t *RedisDAO) SlaveResetImageList(slaveID string, images []image.ImageListItem) error

func (*RedisDAO) SlaveStats ¶

func (t *RedisDAO) SlaveStats(slaveID string) (string, error)

func (*RedisDAO) SlaveStatus ¶

func (t *RedisDAO) SlaveStatus(slaveID string) (map[string]string, error)

func (*RedisDAO) SlaveUUIDList ¶

func (t *RedisDAO) SlaveUUIDList() ([]string, error)

func (*RedisDAO) SlaveUpdateAddToken ¶

func (t *RedisDAO) SlaveUpdateAddToken(token string) error

func (*RedisDAO) SlaveUpdateStats ¶

func (t *RedisDAO) SlaveUpdateStats(slaveID string, stats types.StatsSlave) error

func (*RedisDAO) SlaveUpdateStatus ¶

func (t *RedisDAO) SlaveUpdateStatus(slaveID string, stats types.StatsSlave, resource resource.ResourceAvailable) error

func (*RedisDAO) TestConnection ¶

func (t *RedisDAO) TestConnection() error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL