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 {
	TaskManager          interfaces.TaskInterface
	WorkflowManager      interfaces.WorkflowInterface
	LaunchPlanManager    interfaces.LaunchPlanInterface
	ExecutionManager     interfaces.ExecutionInterface
	NodeExecutionManager interfaces.NodeExecutionInterface
	TaskExecutionManager interfaces.TaskExecutionInterface
	ProjectManager       interfaces.ProjectInterface
	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) 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) GetNodeExecution

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

func (*AdminService) GetNodeExecutionData

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) GetWorkflow

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

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) 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) 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) RegisterProject

func (*AdminService) RelaunchExecution

func (*AdminService) TerminateExecution

func (*AdminService) UpdateLaunchPlan

Directories

Path Synopsis
tests
util