interactive

package
v0.0.0-...-164995d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 10, 2023 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

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