client

Documentation

Index

• func InfoHandler(c *gin.Context)
• func ReverseProxyHandler(c *gin.Context)
• type Client
  • func DefaultClient(desc *PluginInfo) *Client
  • func GetClient() *Client
  • func (c *Client) ApplyConfig(batch *common.Batch, path, content string) error
  • func (c *Client) GetPluginInfo(name string) (*PluginInfo, error)
  • func (c *Client) ListenEvent(event Event, callback EventCallback) error
  • func (c *Client) MachineList() ([]*common.MachineNode, error)
  • func (c *Client) RegisterHandlers(router *gin.Engine)
  • func (c *Client) RunCommand(batch *common.Batch, cmd string) ([]*CmdResult, error)
  • func (c *Client) RunScript(batch *common.Batch, script string, params []string) ([]*CmdResult, error)
  • func (c *Client) ServiceStatus(batch *common.Batch, servicename string) ([]*common.ServiceResult, error)
  • func (c *Client) StartService(batch *common.Batch, serviceName string) ([]*common.ServiceResult, error)
  • func (c *Client) StopService(batch *common.Batch, serviceName string) ([]*common.ServiceResult, error)
  • func (c *Client) UnListenEvent(listenerID string) error
• type CmdResult
• type CmdStruct
• type Event
• type EventCallback
• type PluginInfo
• type ScriptStruct

Functions

func InfoHandler

func InfoHandler(c *gin.Context)

func ReverseProxyHandler

func ReverseProxyHandler(c *gin.Context)

Types

type Client

type Client struct {
	Server     string
	PluginInfo *PluginInfo
}

func DefaultClient

func DefaultClient(desc *PluginInfo) *Client

func GetClient

func GetClient() *Client

func (*Client) ApplyConfig

func (c *Client) ApplyConfig(batch *common.Batch, path, content string) error

func (*Client) GetPluginInfo

func (c *Client) GetPluginInfo(name string) (*PluginInfo, error)

func (*Client) ListenEvent

func (c *Client) ListenEvent(event Event, callback EventCallback) error

注册event事件监听

func (*Client) MachineList

func (c *Client) MachineList() ([]*common.MachineNode, error)

func (*Client) RegisterHandlers

func (c *Client) RegisterHandlers(router *gin.Engine)

RegisterHandlers 注册一些插件标准的API接口，清单如下： GET /plugin_manage/info

func (*Client) RunCommand

func (c *Client) RunCommand(batch *common.Batch, cmd string) ([]*CmdResult, error)

func (*Client) RunScript

func (c *Client) RunScript(batch *common.Batch, script string, params []string) ([]*CmdResult, error)

func (*Client) ServiceStatus

func (c *Client) ServiceStatus(batch *common.Batch, servicename string) ([]*common.ServiceResult, error)

func (*Client) StartService

func (c *Client) StartService(batch *common.Batch, serviceName string) ([]*common.ServiceResult, error)

func (*Client) StopService

func (c *Client) StopService(batch *common.Batch, serviceName string) ([]*common.ServiceResult, error)

func (*Client) UnListenEvent

func (c *Client) UnListenEvent(listenerID string) error

取消注册event事件监听

type CmdResult

type CmdResult struct {
	MachineUUID string
	MachineIP   string
	RetCode     int
	Stdout      string
	Stderr      string
}

type CmdStruct

type CmdStruct struct {
	Batch   *common.Batch `json:"batch"`
	Command string        `json:"command"`
}

type Event

type Event struct {
	ID       int
	MetaData interface{}
}

type EventCallback

type EventCallback func(e *Event)

type PluginInfo

type PluginInfo struct {
	Name        string `json:"name"`
	Version     string `json:"version"`
	Description string `json:"description"`
	Author      string `json:"author"`
	Email       string `json:"email"`
	Url         string `json:"url"`
	PluginType  string `json:"plugin_type"`
	ReverseDest string `json:"reverse_dest"`
}

var BaseInfo *PluginInfo

type ScriptStruct

type ScriptStruct struct {
	Batch  *common.Batch `json:"batch"`
	Script string        `json:"script"`
	Params []string      `json:"params"`
}