utils

Documentation

Index

• type PalletOneDocker
  • func NewPalletOneDocker(dag dboperation.IContractDag, jury core2.IAdapterJury) *PalletOneDocker
  • func (pD *PalletOneDocker) CreateDefaultUserContractNetWork()
  • func (pD *PalletOneDocker) GetAllContainers() ([]docker.APIContainers, error)
  • func (pD *PalletOneDocker) GetAllContainersAddrsWithStatus(cons []docker.APIContainers, status string) ([]string, error)
  • func (pD *PalletOneDocker) PullUserContractImages(n chan<- struct{})
  • func (pD *PalletOneDocker) RemoveExpiredContainers(cons []docker.APIContainers)
  • func (pD *PalletOneDocker) RestartExitedAndUnExpiredContainers(cons []docker.APIContainers)
  • func (pD *PalletOneDocker) RestartUserContractsWhenStartGptn(n1 <-chan struct{}, n2 chan<- struct{})
  • func (pD *PalletOneDocker) RetrieveExpiredContainers(containers []docker.APIContainers) map[string]common.Address
  • func (pD *PalletOneDocker) RmConsOverDisk(cc *list.CCInfo) (sizeRW int64, disk int64, isOver bool)

Types

type PalletOneDocker

type PalletOneDocker struct {
	DockerClient *docker.Client
	// contains filtered or unexported fields
}

func NewPalletOneDocker

func NewPalletOneDocker(dag dboperation.IContractDag, jury core2.IAdapterJury) *PalletOneDocker

func (*PalletOneDocker) CreateDefaultUserContractNetWork

func (pD *PalletOneDocker) CreateDefaultUserContractNetWork()

func (*PalletOneDocker) GetAllContainers

func (pD *PalletOneDocker) GetAllContainers() ([]docker.APIContainers, error)

func (*PalletOneDocker) GetAllContainersAddrsWithStatus

func (pD *PalletOneDocker) GetAllContainersAddrsWithStatus(cons []docker.APIContainers, status string) ([]string, error)

获取用户合约异常退出的监听函数

status: Up， Exited

func (*PalletOneDocker) PullUserContractImages

func (pD *PalletOneDocker) PullUserContractImages(n chan<- struct{})

func (*PalletOneDocker) RemoveExpiredContainers

func (pD *PalletOneDocker) RemoveExpiredContainers(cons []docker.APIContainers)

删除所有过期容器

func (*PalletOneDocker) RestartExitedAndUnExpiredContainers

func (pD *PalletOneDocker) RestartExitedAndUnExpiredContainers(cons []docker.APIContainers)

func (*PalletOneDocker) RestartUserContractsWhenStartGptn

func (pD *PalletOneDocker) RestartUserContractsWhenStartGptn(n1 <-chan struct{}, n2 chan<- struct{})

func (*PalletOneDocker) RetrieveExpiredContainers

func (pD *PalletOneDocker) RetrieveExpiredContainers(containers []docker.APIContainers) map[string]common.Address

func (*PalletOneDocker) RmConsOverDisk

func (pD *PalletOneDocker) RmConsOverDisk(cc *list.CCInfo) (sizeRW int64, disk int64, isOver bool)

调用的时候，若调用完发现磁盘使用超过系统上限，则kill掉并移除