processing

package
v1.0.1 Latest Latest
Warning

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

Go to latest
Published: Feb 16, 2026 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ReloadServices

func ReloadServices(cnf conf.ConfigYAML)

func Start

func Start(cnf conf.ConfigYAML, multiAccess bool) int

func StartServices

func StartServices(cnf conf.ConfigYAML, previouslyStopped []string, sent []string)

func StopServices

func StopServices(cnf conf.ConfigYAML) []string

Types

type Command

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

func NewCommandTask

func NewCommandTask(cnf conf.ConfigYAML, cmd *exec.Cmd, name string) *Command

func (*Command) StartAndWait

func (c *Command) StartAndWait()

type CommandToConn

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

func NewCommandToConnTask

func NewCommandToConnTask(conn io.ReadWriteCloser, keepAlive bool, name string, cmd *exec.Cmd, cnf conf.ConfigYAML) *CommandToConn

func (*CommandToConn) WaitOnCompletion

func (t *CommandToConn) WaitOnCompletion()

type ConnToCommand

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

func NewConnToCommandTask

func NewConnToCommandTask(conn io.ReadWriteCloser, keepAlive bool, name string, cmd *exec.Cmd, cnf conf.ConfigYAML) *ConnToCommand

func (*ConnToCommand) WaitOnCompletion

func (t *ConnToCommand) WaitOnCompletion()

type File

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

func NewFileTask

func NewFileTask(conn net.Conn, cnf conf.ConfigYAML) *File

func (*File) WaitOnCompletion

func (f *File) WaitOnCompletion()

type RsyncIngester

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

func NewRsyncIngester

func NewRsyncIngester(cnf conf.ConfigYAML, conn *comm.Client) *RsyncIngester

func (*RsyncIngester) Wait

func (r *RsyncIngester) Wait()

type RsyncSender

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

func NewRsyncSender

func NewRsyncSender(cnf conf.ConfigYAML, conn *comm.Client) *RsyncSender

func (*RsyncSender) StartAndWait

func (s *RsyncSender) StartAndWait()

type UnFile

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

func NewUnFileTask

func NewUnFileTask(conn net.Conn, cnf conf.ConfigYAML) *UnFile

func (*UnFile) WaitOnCompletion

func (f *UnFile) WaitOnCompletion()

Jump to

Keyboard shortcuts

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