mmp

package
v0.0.3 Latest Latest
Warning

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

Go to latest
Published: Jun 7, 2020 License: AGPL-3.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source
const (
	PayloadTypeNodeInit = iota
	PayloadTypeCancelSession

	PayloadTypeCommandShellExec
	PayloadTypeCommandShellExit
	PayloadTypeCommandShellInput
	PayloadTypeCommandShellOutput
	PayloadTypeCommandShellDisabled

	PayloadTypeTransferInit
	PayloadTypeTransferData
	PayloadTypeTransferAck
	PayloadTypeTransferDisabled

	PayloadTypePortFwdListen
	PayloadTypePortFwdDial
	PayloadTypePortFwdDialAck
	PayloadTypePortFwdEnd
	PayloadTypePortFwdData
	PayloadTypePortFwdDisabled

	PayloadTypeWorkflowExpedite
	PayloadTypeWorkflowSchedule
	PayloadTypeWorkflowResponse
)

Variables

View Source
var RecvCommandQueue = make(chan *mmp.Payload, 128)
View Source
var SendCommandQueue = make(chan *mmp.Payload, 128)

Functions

func Atd

func Atd(w *runtime.Wrkr)

func ClosePortFwd

func ClosePortFwd(srcPort, dstPort uint32, proto, srcNodeID, dstNodeID string, wg *sync.WaitGroup)

func CmdEventsHandler

func CmdEventsHandler(w *runtime.Wrkr)

func Connected

func Connected()

func Cron

func Cron(w *runtime.Wrkr)

func Disconnected

func Disconnected()

func NewPortFwd

func NewPortFwd(authKey *auth.AuthKey, srcPort, dstPort uint32, proto, srcID, dstID string, interactive bool)

func NewShellExit

func NewShellExit(srcID string, p *mmp.Payload) *mmp.Payload

func NewShellRequest

func NewShellRequest(authKey *auth.AuthKey, dstID string, c string, args ...string)

func NewTransfer

func NewTransfer(authKey *auth.AuthKey, srcFilePath, dstFilePath, srcID, dstID string, interactive bool)

func NewWorkflowExpedite

func NewWorkflowExpedite(wf *workflow.Workflow)

NewWorkflowExpedite create a workflow mmp pdu for every target. This function usually will be executed on controllers.

func NewWorkflowSchedule

func NewWorkflowSchedule(wf *workflow.Workflow)

func Processor

func Processor(ctx context.Context, p *mmp.Payload) error

Types

This section is empty.

Jump to

Keyboard shortcuts

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