server

Documentation

Index

• type Kobe
  • func NewKobe() *Kobe
  • func (k *Kobe) CreateProject(ctx context.Context, req *api.CreateProjectRequest) (*api.CreateProjectResponse, error)
  • func (k *Kobe) GetInventory(ctx context.Context, req *api.GetInventoryRequest) (*api.GetInventoryResponse, error)
  • func (k *Kobe) GetResult(ctx context.Context, req *api.GetResultRequest) (*api.GetResultResponse, error)
  • func (k *Kobe) ListProject(ctx context.Context, req *api.ListProjectRequest) (*api.ListProjectResponse, error)
  • func (k *Kobe) ListResult(ctx context.Context, req *api.ListResultRequest) (*api.ListResultResponse, error)
  • func (k *Kobe) RunAdhoc(ctx context.Context, req *api.RunAdhocRequest) (*api.RunAdhocResult, error)
  • func (k *Kobe) RunPlaybook(ctx context.Context, req *api.RunPlaybookRequest) (*api.RunPlaybookResult, error)
  • func (k *Kobe) WatchResult(req *api.WatchRequest, server api.KobeApi_WatchResultServer) error
• type Pool
  • func NewPool() *Pool
  • func (p *Pool) Commit(taskFunc TaskFunc)
  • func (p *Pool) IsEmpty() bool
  • func (p *Pool) Len() int
• type ProjectManager
  • func (pm ProjectManager) CreateProject(name, source string) (*api.Project, error)
  • func (pm ProjectManager) GetProject(name string) (*api.Project, error)
  • func (pm ProjectManager) IsProjectExists(name string) (bool, error)
  • func (pm ProjectManager) SearchProjects() ([]*api.Project, error)
• type RunnerManager
  • func (rm *RunnerManager) CreateAdhocRunner(pattern, module, param string) (*ansible.AdhocRunner, error)
  • func (rm *RunnerManager) CreatePlaybookRunner(projectName, playbookName, tag string) (*ansible.PlaybookRunner, error)
• type TaskFunc

Types

type Kobe

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

func NewKobe

func NewKobe() *Kobe

func (*Kobe) CreateProject

func (k *Kobe) CreateProject(ctx context.Context, req *api.CreateProjectRequest) (*api.CreateProjectResponse, error)

func (*Kobe) GetInventory

func (k *Kobe) GetInventory(ctx context.Context, req *api.GetInventoryRequest) (*api.GetInventoryResponse, error)

func (*Kobe) GetResult

func (k *Kobe) GetResult(ctx context.Context, req *api.GetResultRequest) (*api.GetResultResponse, error)

func (*Kobe) ListProject

func (k *Kobe) ListProject(ctx context.Context, req *api.ListProjectRequest) (*api.ListProjectResponse, error)

func (*Kobe) ListResult

func (k *Kobe) ListResult(ctx context.Context, req *api.ListResultRequest) (*api.ListResultResponse, error)

func (*Kobe) RunAdhoc

func (k *Kobe) RunAdhoc(ctx context.Context, req *api.RunAdhocRequest) (*api.RunAdhocResult, error)

func (*Kobe) RunPlaybook

func (k *Kobe) RunPlaybook(ctx context.Context, req *api.RunPlaybookRequest) (*api.RunPlaybookResult, error)

func (*Kobe) WatchResult

func (k *Kobe) WatchResult(req *api.WatchRequest, server api.KobeApi_WatchResultServer) error

type Pool

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

func NewPool

func NewPool() *Pool

func (*Pool) Commit

func (p *Pool) Commit(taskFunc TaskFunc)

func (*Pool) IsEmpty

func (p *Pool) IsEmpty() bool

func (*Pool) Len

func (p *Pool) Len() int

type ProjectManager

type ProjectManager struct {
}

func (ProjectManager) CreateProject

func (pm ProjectManager) CreateProject(name, source string) (*api.Project, error)

func (ProjectManager) GetProject

func (pm ProjectManager) GetProject(name string) (*api.Project, error)

func (ProjectManager) IsProjectExists

func (pm ProjectManager) IsProjectExists(name string) (bool, error)

func (ProjectManager) SearchProjects

func (pm ProjectManager) SearchProjects() ([]*api.Project, error)

type RunnerManager

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

func (*RunnerManager) CreateAdhocRunner

func (rm *RunnerManager) CreateAdhocRunner(pattern, module, param string) (*ansible.AdhocRunner, error)

func (*RunnerManager) CreatePlaybookRunner

func (rm *RunnerManager) CreatePlaybookRunner(projectName, playbookName, tag string) (*ansible.PlaybookRunner, error)

type TaskFunc

type TaskFunc func()