server

package

v1.0.0-alpha Latest Latest Go to latest Published: Oct 13, 2021 License: MIT Imports: 17 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type KubeOps struct {
	api.UnimplementedKubeOpsApiServer
	// contains filtered or unexported fields
}

func NewKubeOps() *KubeOps

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

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

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

func (k *KubeOps) Health(ctx context.Context, req *api.HealthRequest) (*api.HealthResponse, error)

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

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

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

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

func (k *KubeOps) WatchResult(req *api.WatchRequest, server api.KubeOpsApi_WatchResultServer) error

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

func NewPool() *Pool

func (p *Pool) Commit(taskFunc TaskFunc)

func (p *Pool) IsEmpty() bool

func (p *Pool) Len() int

type ProjectManager struct {
}

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 struct {
	// contains filtered or unexported fields
}

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

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

type TaskFunc func()