app

package
v0.69.0 Latest Latest
Warning

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

 Go to latest Published: Oct 2, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	UndefinedShutdownTimeoutSec = 0
	DefaultShutdownTimeoutSec   = 10
	EnvReplicaNum               = "PC_REPLICA_NUM"
	LogReplicaNum               = "{" + EnvReplicaNum + "}"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Commander added in v0.55.0 

type Commander interface {
	Start() error
	Wait() error
	ExitCode() int
	Pid() int
	SetEnv([]string)
	SetDir(string)
	StdoutPipe() (io.ReadCloser, error)
	StderrPipe() (io.ReadCloser, error)
	Stop(int, bool) error
	SetCmdArgs()
}

type IProject added in v0.50.0 

type IProject interface {
	ShutDownProject() error
	IsRemote() bool
	ErrorForSecs() int
	GetHostName() (string, error)

	GetLogLength() int
	GetLogsAndSubscribe(name string, observer pclog.LogObserver) error
	UnSubscribeLogger(name string, observer pclog.LogObserver) error
	GetProcessLog(name string, offsetFromEnd, limit int) ([]string, error)

	GetLexicographicProcessNames() ([]string, error)
	GetProcessInfo(name string) (*types.ProcessConfig, error)
	GetProcessState(name string) (*types.ProcessState, error)
	GetProcessesState() (*types.ProcessesState, error)
	StopProcess(name string) error
	StopProcesses(names []string) ([]string, error)
	StartProcess(name string) error
	RestartProcess(name string) error
	ScaleProcess(name string, scale int) error
	GetProcessPorts(name string) (*types.ProcessPorts, error)
}

IProject holds all the functions from the project struct that are being consumed by the tui package

type Process 

type Process struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewProcess 

func NewProcess(
	globalEnv []string,
	logger pclog.PcLogger,
	procConf *types.ProcessConfig,
	processState *types.ProcessState,
	procLog *pclog.ProcessLogBuffer,
	shellConfig command.ShellConfig,
) *Process

type ProjectRunner added in v0.40.0 

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

func NewProjectRunner added in v0.40.0 

func NewProjectRunner(project *types.Project, processesToRun []string, noDeps bool) (*ProjectRunner, error)

func (*ProjectRunner) ErrorForSecs added in v0.50.0 

func (p *ProjectRunner) ErrorForSecs() int

func (*ProjectRunner) GetDependenciesOrderNames added in v0.40.0 

func (p *ProjectRunner) GetDependenciesOrderNames() ([]string, error)

func (*ProjectRunner) GetHostName added in v0.50.0 

func (p *ProjectRunner) GetHostName() (string, error)

func (*ProjectRunner) GetLexicographicProcessNames added in v0.50.0 

func (p *ProjectRunner) GetLexicographicProcessNames() ([]string, error)

func (*ProjectRunner) GetLogLength added in v0.40.0 

func (p *ProjectRunner) GetLogLength() int

func (*ProjectRunner) GetLogsAndSubscribe added in v0.40.0 

func (p *ProjectRunner) GetLogsAndSubscribe(name string, observer pclog.LogObserver) error

func (*ProjectRunner) GetProcessInfo added in v0.40.0 

func (p *ProjectRunner) GetProcessInfo(name string) (*types.ProcessConfig, error)

func (*ProjectRunner) GetProcessLog added in v0.40.0 

func (p *ProjectRunner) GetProcessLog(name string, offsetFromEnd, limit int) ([]string, error)

func (*ProjectRunner) GetProcessLogLength added in v0.40.0 

func (p *ProjectRunner) GetProcessLogLength(name string) int

func (*ProjectRunner) GetProcessPorts added in v0.55.0 

func (p *ProjectRunner) GetProcessPorts(name string) (*types.ProcessPorts, error)

func (*ProjectRunner) GetProcessState added in v0.40.0 

func (p *ProjectRunner) GetProcessState(name string) (*types.ProcessState, error)

func (*ProjectRunner) GetProcessesState added in v0.50.0 

func (p *ProjectRunner) GetProcessesState() (*types.ProcessesState, error)

func (*ProjectRunner) GetProject added in v0.40.0 

func (p *ProjectRunner) GetProject() *types.Project

func (*ProjectRunner) IsRemote added in v0.50.0 

func (p *ProjectRunner) IsRemote() bool

func (*ProjectRunner) RestartProcess added in v0.40.0 

func (p *ProjectRunner) RestartProcess(name string) error

func (*ProjectRunner) Run added in v0.40.0 

func (p *ProjectRunner) Run() int

func (*ProjectRunner) ScaleProcess added in v0.55.0 

func (p *ProjectRunner) ScaleProcess(name string, scale int) error

func (*ProjectRunner) ShutDownProject added in v0.40.0 

func (p *ProjectRunner) ShutDownProject() error

func (*ProjectRunner) StartProcess added in v0.40.0 

func (p *ProjectRunner) StartProcess(name string) error

func (*ProjectRunner) StopProcess added in v0.40.0 

func (p *ProjectRunner) StopProcess(name string) error

func (*ProjectRunner) StopProcesses added in v0.60.0 

func (p *ProjectRunner) StopProcesses(names []string) ([]string, error)

func (*ProjectRunner) UnSubscribeLogger added in v0.40.0 

func (p *ProjectRunner) UnSubscribeLogger(name string, observer pclog.LogObserver) error

func (*ProjectRunner) WithProcesses added in v0.50.0 

func (p *ProjectRunner) WithProcesses(names []string, fn func(process types.ProcessConfig) error) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.