interactive

Documentation

Index

• type ForkProcess
  • func NewForkProcess() *ForkProcess
  • func (f *ForkProcess) InitFork(execDir string, args0 string, args []string, log *logrus.Logger) error
  • func (f *ForkProcess) Start(log *logrus.Logger) (int, error)
• type InfoAll
• type InfoAllStatistics
  • func NewInfoAllDisplay() *InfoAllStatistics
  • func (i *InfoAllStatistics) Set(info *InfoAll)
  • func (i *InfoAllStatistics) ToString() string
• type InfoDetail
• type InfoDetailStatistics
  • func NewInfoDetailDisplay() *InfoDetailStatistics
  • func (i *InfoDetailStatistics) Set(detail *InfoDetail)
  • func (i *InfoDetailStatistics) ToString() string
• type Processor
• type RpcBody
  • func InitRpcClient(log *logrus.Logger) *RpcBody
  • func (c *RpcBody) Close()
  • func (c *RpcBody) ConnectToServer(pi ddsutils.ProcessInfo) (*ddsrpc.RpcClient, error)
  • func (c *RpcBody) Detail(pi *ddsutils.ProcessInfo) (*string, error)
  • func (c *RpcBody) GetAllGroupAndProcessFile() (pfi []ddsutils.ProcessInfo, err error)
  • func (c *RpcBody) List() (*string, error)

Types

type ForkProcess

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

func NewForkProcess

func NewForkProcess() *ForkProcess

func (*ForkProcess) InitFork

func (f *ForkProcess) InitFork(execDir string, args0 string, args []string, log *logrus.Logger) error

func (*ForkProcess) Start

func (f *ForkProcess) Start(log *logrus.Logger) (int, error)

type InfoAll

type InfoAll struct {
	Type,
	Program,
	Status,
	GroupID,
	Lag,
	SinceChkpt string
}

type InfoAllStatistics

type InfoAllStatistics struct {
	InfoDisplay []*InfoAll
}

func NewInfoAllDisplay

func NewInfoAllDisplay() *InfoAllStatistics

func (*InfoAllStatistics) Set

func (i *InfoAllStatistics) Set(info *InfoAll)

func (*InfoAllStatistics) ToString

func (i *InfoAllStatistics) ToString() string

type InfoDetail

type InfoDetail struct {
	Program,
	GroupID,
	Dbtype,
	LastStarted,
	Lag,
	SinceChkpt,
	Status,
	FileNumber,
	FileOffset,
	LogNumber,
	LogOffset string // 日志文件rba
}

type InfoDetailStatistics

type InfoDetailStatistics struct {
	InfoDetailDisplay []*InfoDetail
}

func NewInfoDetailDisplay

func NewInfoDetailDisplay() *InfoDetailStatistics

func (*InfoDetailStatistics) Set

func (i *InfoDetailStatistics) Set(detail *InfoDetail)

func (*InfoDetailStatistics) ToString

func (i *InfoDetailStatistics) ToString() string

type Processor

type Processor struct {
	// RPC *ddsrpc.RpcClient // Communication body
	MD ddsmetadata.MetaData // 进程元数据
	ddsmetadata.MdHandle
}

type RpcBody

type RpcBody struct {
	Pro map[string]*Processor
	// contains filtered or unexported fields
}

func InitRpcClient

func InitRpcClient(log *logrus.Logger) *RpcBody

func (*RpcBody) Close

func (c *RpcBody) Close()

func (*RpcBody) ConnectToServer

func (c *RpcBody) ConnectToServer(pi ddsutils.ProcessInfo) (*ddsrpc.RpcClient, error)

func (*RpcBody) Detail

func (c *RpcBody) Detail(pi *ddsutils.ProcessInfo) (*string, error)

func (*RpcBody) GetAllGroupAndProcessFile

func (c *RpcBody) GetAllGroupAndProcessFile() (pfi []ddsutils.ProcessInfo, err error)

func (*RpcBody) List

func (c *RpcBody) List() (*string, error)