sessionplugin

Documentation

Overview

Package sessionplugin implements functionality common to all session manager plugins

Index

• type ISessionPlugin
• type NewPluginFunc
• type SessionPlugin
  • func NewPlugin(context context.T, newPluginFunc NewPluginFunc) (*SessionPlugin, error)
  • func (p *SessionPlugin) Execute(config contracts.Configuration, cancelFlag task.CancelFlag, ...)

Types

type ISessionPlugin

type ISessionPlugin interface {
	GetPluginParameters(parameters interface{}) interface{}
	RequireHandshake() bool
	Execute(config contracts.Configuration, cancelFlag task.CancelFlag, output iohandler.IOHandler, dataChannel datachannel.IDataChannel)
	InputStreamMessageHandler(log log.T, streamDataMessage mgsContracts.AgentMessage) error
}

ISessionPlugin interface represents functions that need to be implemented by all session manager plugins

type NewPluginFunc

type NewPluginFunc func(context.T) (ISessionPlugin, error)

type SessionPlugin

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

SessionPlugin is the wrapper for all session manager plugins and implements all functions of Runpluginutil.T interface

func NewPlugin

func NewPlugin(context context.T, newPluginFunc NewPluginFunc) (*SessionPlugin, error)

NewPlugin returns a new instance of SessionPlugin which wraps a plugin that implements ISessionPlugin

func (*SessionPlugin) Execute

func (p *SessionPlugin) Execute(
	config contracts.Configuration,
	cancelFlag task.CancelFlag,
	output iohandler.IOHandler)

Execute sets up datachannel and starts execution of session manager plugin like shell