service

Documentation

Index

• Variables
• type CacheManager
  • func NewCacheManager() *CacheManager
  • func (cm *CacheManager) Download(cmdIn *domain.ShellIn) string
  • func (cm *CacheManager) Resolve(cmdIn *domain.ShellIn)
  • func (cm *CacheManager) Upload(cmdIn *domain.ShellIn, cacheDir string)
• type CmdService
  • func GetCmdService() *CmdService
  • func (s *CmdService) Execute(bytes []byte) error
  • func (s *CmdService) IsRunning() bool
• type PluginManager
  • func NewPluginManager(dir, server string) *PluginManager
  • func (p *PluginManager) Load(name string) error

Variables

var (
	ErrorCmdIsRunning       = errors.New("agent: cmd is running, service not available")
	ErrorCmdUnsupportedType = errors.New("agent: unsupported cmd type")

	ErrorCmdScriptIsPersented     = errors.New("agent: the scripts should be empty for session open")
	ErrorCmdMissingSessionID      = errors.New("agent: the session id is required for cmd")
	ErrorCmdSessionNotFound       = errors.New("agent: session not found")
	ErrorCmdSessionMissingScripts = errors.New("agent: script is missing")
)

Types

type CacheManager

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

func NewCacheManager

func NewCacheManager() *CacheManager

func (*CacheManager) Download

func (cm *CacheManager) Download(cmdIn *domain.ShellIn) string

Download download cache into a temp dir and return

func (*CacheManager) Resolve

func (cm *CacheManager) Resolve(cmdIn *domain.ShellIn)

Resolve resolve env vars in cache key and paths

func (*CacheManager) Upload

func (cm *CacheManager) Upload(cmdIn *domain.ShellIn, cacheDir string)

Upload upload all files/dirs from cache dir

type CmdService

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

CmdService receive and execute cmd

func GetCmdService

func GetCmdService() *CmdService

GetCmdService get singleton of cmd service

func (*CmdService) Execute

func (s *CmdService) Execute(bytes []byte) error

Execute execute cmd according to the type

func (*CmdService) IsRunning

func (s *CmdService) IsRunning() bool

IsRunning check is available to run cmd

type PluginManager

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

func NewPluginManager

func NewPluginManager(dir, server string) *PluginManager

func (*PluginManager) Load

func (p *PluginManager) Load(name string) error