process

Documentation

Index

• type Process
  • func InitProcess(conf cfg.ProcessConfig) (*Process, error)
  • func (ps *Process) Close() error
  • func (ps *Process) Entityes() []entity.Entity
  • func (ps *Process) Execute() error
  • func (p *Process) Stat() *ProcessStat
• type ProcessStat
  • func (stat *ProcessStat) Entities() []entity.EntityInfo
• type Volume

Types

type Process

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

func InitProcess

func InitProcess(conf cfg.ProcessConfig) (*Process, error)

func (*Process) Close

func (ps *Process) Close() error

func (*Process) Entityes

func (ps *Process) Entityes() []entity.Entity

func (*Process) Execute

func (ps *Process) Execute() error

func (*Process) Stat

func (p *Process) Stat() *ProcessStat

type ProcessStat

type ProcessStat struct {
	Date time.Time
	// contains filtered or unexported fields
}

func (*ProcessStat) Entities

func (stat *ProcessStat) Entities() []entity.EntityInfo

type Volume

type Volume map[string]manager.ManagerAtomic