adminservice

package
v0.6.68 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 17, 2021 License: Apache-2.0 Imports: 32 Imported by: 2

Documentation

Overview

Per endpoint service Metrics.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AdminMetrics

type AdminMetrics struct {
	Scope        promutils.Scope
	PanicCounter prometheus.Counter
	// contains filtered or unexported fields
}

func InitMetrics

func InitMetrics(adminScope promutils.Scope) AdminMetrics

type AdminService

type AdminService struct {
	service.UnimplementedAdminServiceServer
	TaskManager          interfaces.TaskInterface
	WorkflowManager      interfaces.WorkflowInterface
	LaunchPlanManager    interfaces.LaunchPlanInterface
	ExecutionManager     interfaces.ExecutionInterface
	NodeExecutionManager interfaces.NodeExecutionInterface
	TaskExecutionManager interfaces.TaskExecutionInterface
	ProjectManager       interfaces.ProjectInterface
	ResourceManager      interfaces.ResourceInterface
	NamedEntityManager   interfaces.NamedEntityInterface
	VersionManager       interfaces.VersionInterface
	Metrics              AdminMetrics
}

func NewAdminServer

func NewAdminServer(kubeConfig, master string) *AdminService

func (*AdminService) CreateExecution

func (*AdminService) CreateLaunchPlan

func (*AdminService) CreateNodeEvent

func (*AdminService) CreateTask

func (*AdminService) CreateTaskEvent

func (*AdminService) CreateWorkflow

func (*AdminService) CreateWorkflowEvent

func (*AdminService) DeleteProjectDomainAttributes added in v0.3.38

func (*AdminService) DeleteWorkflowAttributes added in v0.3.38

func (*AdminService) GetActiveLaunchPlan

func (m *AdminService) GetActiveLaunchPlan(ctx context.Context, request *admin.ActiveLaunchPlanRequest) (*admin.LaunchPlan, error)

func (*AdminService) GetExecution

func (m *AdminService) GetExecution(
	ctx context.Context, request *admin.WorkflowExecutionGetRequest) (*admin.Execution, error)

func (*AdminService) GetLaunchPlan

func (m *AdminService) GetLaunchPlan(ctx context.Context, request *admin.ObjectGetRequest) (*admin.LaunchPlan, error)

func (*AdminService) GetNamedEntity added in v0.1.4

func (m *AdminService) GetNamedEntity(ctx context.Context, request *admin.NamedEntityGetRequest) (*admin.NamedEntity, error)

func (*AdminService) GetNodeExecution

func (m *AdminService) GetNodeExecution(
	ctx context.Context, request *admin.NodeExecutionGetRequest) (*admin.NodeExecution, error)

func (*AdminService) GetNodeExecutionData

func (*AdminService) GetProjectDomainAttributes added in v0.3.38

func (*AdminService) GetTask

func (m *AdminService) GetTask(ctx context.Context, request *admin.ObjectGetRequest) (*admin.Task, error)

func (*AdminService) GetTaskExecution

func (m *AdminService) GetTaskExecution(
	ctx context.Context, request *admin.TaskExecutionGetRequest) (*admin.TaskExecution, error)

func (*AdminService) GetTaskExecutionData

func (*AdminService) GetVersion added in v0.4.10

func (*AdminService) GetWorkflow

func (m *AdminService) GetWorkflow(ctx context.Context, request *admin.ObjectGetRequest) (*admin.Workflow, error)

func (*AdminService) GetWorkflowAttributes added in v0.3.38

func (*AdminService) ListActiveLaunchPlans

func (m *AdminService) ListActiveLaunchPlans(ctx context.Context, request *admin.ActiveLaunchPlanListRequest) (
	*admin.LaunchPlanList, error)

func (*AdminService) ListExecutions

func (m *AdminService) ListExecutions(
	ctx context.Context, request *admin.ResourceListRequest) (*admin.ExecutionList, error)

func (*AdminService) ListLaunchPlanIds

func (*AdminService) ListLaunchPlans

func (m *AdminService) ListLaunchPlans(ctx context.Context, request *admin.ResourceListRequest) (
	*admin.LaunchPlanList, error)

func (*AdminService) ListMatchableAttributes added in v0.3.38

func (*AdminService) ListNamedEntities added in v0.1.4

func (m *AdminService) ListNamedEntities(ctx context.Context, request *admin.NamedEntityListRequest) (
	*admin.NamedEntityList, error)

func (*AdminService) ListNodeExecutions

func (m *AdminService) ListNodeExecutions(
	ctx context.Context, request *admin.NodeExecutionListRequest) (*admin.NodeExecutionList, error)

func (*AdminService) ListNodeExecutionsForTask

func (m *AdminService) ListNodeExecutionsForTask(
	ctx context.Context, request *admin.NodeExecutionForTaskListRequest) (*admin.NodeExecutionList, error)

func (*AdminService) ListProjects

func (m *AdminService) ListProjects(ctx context.Context, request *admin.ProjectListRequest) (*admin.Projects, error)

func (*AdminService) ListTaskExecutions

func (m *AdminService) ListTaskExecutions(
	ctx context.Context, request *admin.TaskExecutionListRequest) (*admin.TaskExecutionList, error)

func (*AdminService) ListTaskIds

func (*AdminService) ListTasks

func (m *AdminService) ListTasks(ctx context.Context, request *admin.ResourceListRequest) (*admin.TaskList, error)

func (*AdminService) ListWorkflowIds

func (*AdminService) ListWorkflows

func (m *AdminService) ListWorkflows(ctx context.Context, request *admin.ResourceListRequest) (*admin.WorkflowList, error)

func (*AdminService) RecoverExecution added in v0.6.18

func (*AdminService) RegisterProject

func (*AdminService) RelaunchExecution

func (*AdminService) TerminateExecution

func (*AdminService) UpdateLaunchPlan

func (*AdminService) UpdateNamedEntity added in v0.1.4

func (*AdminService) UpdateProject added in v0.3.38

func (m *AdminService) UpdateProject(ctx context.Context, request *admin.Project) (
	*admin.ProjectUpdateResponse, error)

func (*AdminService) UpdateProjectDomainAttributes added in v0.1.4

func (*AdminService) UpdateWorkflowAttributes added in v0.3.38

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL