client

Documentation

Index

• Constants
• type KobeClient
  • func NewKobeClient(host string, port int) *KobeClient
  • func (c *KobeClient) CancelTask(taskId string) error
  • func (c *KobeClient) CreateProject(name string, source string) (*api.Project, error)
  • func (c *KobeClient) CreateProjectWithAuth(name string, source string, username string, password string) (*api.Project, error)
  • func (c KobeClient) DeleteProject(name string) error
  • func (c *KobeClient) GetInvertory(id string) (*api.Inventory, error)
  • func (c *KobeClient) GetResult(taskId string) (*api.Result, error)
  • func (c KobeClient) ListProject() ([]*api.Project, error)
  • func (c *KobeClient) ListResult() ([]*api.Result, error)
  • func (c KobeClient) RunAdhoc(pattern, module, param string, inventory *api.Inventory) (*api.Result, error)
  • func (c KobeClient) RunPlaybook(project, playbook, tag string, inventory *api.Inventory) (*api.Result, error)
  • func (c *KobeClient) WatchRun(taskId string, writer io.Writer) error
  • func (c *KobeClient) WatchRunWithFlush(taskId string, writer io.Writer) error
• type Msg
  • func NewJsonMsg(data string) *Msg
  • func NewTextMsg(data string) *Msg

Constants

const (
	MSG_TYPE_TEXT = 1
	MSG_TYPE_JSON = 2
)

Types

type KobeClient

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

func NewKobeClient

func NewKobeClient(host string, port int) *KobeClient

func (*KobeClient) CancelTask

func (c *KobeClient) CancelTask(taskId string) error

func (*KobeClient) CreateProject

func (c *KobeClient) CreateProject(name string, source string) (*api.Project, error)

func (*KobeClient) CreateProjectWithAuth

func (c *KobeClient) CreateProjectWithAuth(name string, source string, username string, password string) (*api.Project, error)

func (KobeClient) DeleteProject

func (c KobeClient) DeleteProject(name string) error

func (*KobeClient) GetInvertory

func (c *KobeClient) GetInvertory(id string) (*api.Inventory, error)

func (*KobeClient) GetResult

func (c *KobeClient) GetResult(taskId string) (*api.Result, error)

func (KobeClient) ListProject

func (c KobeClient) ListProject() ([]*api.Project, error)

func (*KobeClient) ListResult

func (c *KobeClient) ListResult() ([]*api.Result, error)

func (KobeClient) RunAdhoc

func (c KobeClient) RunAdhoc(pattern, module, param string, inventory *api.Inventory) (*api.Result, error)

func (KobeClient) RunPlaybook

func (c KobeClient) RunPlaybook(project, playbook, tag string, inventory *api.Inventory) (*api.Result, error)

func (*KobeClient) WatchRun

func (c *KobeClient) WatchRun(taskId string, writer io.Writer) error

func (*KobeClient) WatchRunWithFlush

func (c *KobeClient) WatchRunWithFlush(taskId string, writer io.Writer) error

type Msg

type Msg struct {
	Type int
	Data string
}

func NewJsonMsg

func NewJsonMsg(data string) *Msg

func NewTextMsg

func NewTextMsg(data string) *Msg