daemon

Documentation

Index

• Constants
• Variables
• func IsInternalJobName(s string) bool
• func NewPProfServer(ctx context.Context) *pprofServer
• func Run(ctx context.Context, conf *config.Config) error
• type GlobalStatus
• type Logger
• type PprofServerControlMsg
• type Status

Constants

const (
	ControlJobEndpointPProf   string = "/debug/pprof"
	ControlJobEndpointVersion string = "/version"
	ControlJobEndpointStatus  string = "/status"
	ControlJobEndpointSignal  string = "/signal"
)

Variables

var DaemonCmd = &cli.Subcommand{
	Use:   "daemon",
	Short: "run the zrepl daemon",
	Run: func(ctx context.Context, subcommand *cli.Subcommand, args []string) error {
		return Run(ctx, subcommand.Config())
	},
}

Functions

func IsInternalJobName

func IsInternalJobName(s string) bool

func NewPProfServer

func NewPProfServer(ctx context.Context) *pprofServer

func Run

func Run(ctx context.Context, conf *config.Config) error

Types

type GlobalStatus

type GlobalStatus struct {
	ZFSCmds   *zfscmd.Report
	Envconst  *envconst.Report
	OsEnviron []string
}

type Logger

type Logger = logger.Logger

type PprofServerControlMsg

type PprofServerControlMsg struct {
	// Whether the server should listen for requests on the given address
	Run bool
	// Must be set if Run is true, undefined otherwise
	HttpListenAddress string
}

type Status

type Status struct {
	Jobs   map[string]*job.Status
	Global GlobalStatus
}