orchestrator

package
v1.3.11 Latest Latest
Warning

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

 Go to latest Published: Jan 11, 2022 License: Apache-2.0 Imports: 18 Imported by: 4

Documentation

Overview

Package orchestrator is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_orchestrator_proto protoreflect.FileDescriptor
View Source 
var Orchestrator_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "clouditor.Orchestrator",
	HandlerType: (*OrchestratorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterAssessmentTool",
			Handler:    _Orchestrator_RegisterAssessmentTool_Handler,
		},
		{
			MethodName: "ListAssessmentTools",
			Handler:    _Orchestrator_ListAssessmentTools_Handler,
		},
		{
			MethodName: "GetAssessmentTool",
			Handler:    _Orchestrator_GetAssessmentTool_Handler,
		},
		{
			MethodName: "UpdateAssessmentTool",
			Handler:    _Orchestrator_UpdateAssessmentTool_Handler,
		},
		{
			MethodName: "DeregisterAssessmentTool",
			Handler:    _Orchestrator_DeregisterAssessmentTool_Handler,
		},
		{
			MethodName: "StoreAssessmentResult",
			Handler:    _Orchestrator_StoreAssessmentResult_Handler,
		},
		{
			MethodName: "ListMetrics",
			Handler:    _Orchestrator_ListMetrics_Handler,
		},
		{
			MethodName: "GetMetric",
			Handler:    _Orchestrator_GetMetric_Handler,
		},
		{
			MethodName: "RegisterCloudService",
			Handler:    _Orchestrator_RegisterCloudService_Handler,
		},
		{
			MethodName: "UpdateCloudService",
			Handler:    _Orchestrator_UpdateCloudService_Handler,
		},
		{
			MethodName: "GetCloudService",
			Handler:    _Orchestrator_GetCloudService_Handler,
		},
		{
			MethodName: "ListCloudServices",
			Handler:    _Orchestrator_ListCloudServices_Handler,
		},
		{
			MethodName: "RemoveCloudService",
			Handler:    _Orchestrator_RemoveCloudService_Handler,
		},
		{
			MethodName: "GetMetricConfiguration",
			Handler:    _Orchestrator_GetMetricConfiguration_Handler,
		},
		{
			MethodName: "ListMetricConfigurations",
			Handler:    _Orchestrator_ListMetricConfigurations_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StoreAssessmentResults",
			Handler:       _Orchestrator_StoreAssessmentResults_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "orchestrator.proto",
}

Orchestrator_ServiceDesc is the grpc.ServiceDesc for Orchestrator service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterOrchestratorHandler 

func RegisterOrchestratorHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterOrchestratorHandler registers the http handlers for service Orchestrator to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterOrchestratorHandlerClient 

func RegisterOrchestratorHandlerClient(ctx context.Context, mux *runtime.ServeMux, client OrchestratorClient) error

RegisterOrchestratorHandlerClient registers the http handlers for service Orchestrator to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "OrchestratorClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "OrchestratorClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "OrchestratorClient" to call the correct interceptors.

func RegisterOrchestratorHandlerFromEndpoint 

func RegisterOrchestratorHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterOrchestratorHandlerFromEndpoint is same as RegisterOrchestratorHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterOrchestratorHandlerServer 

func RegisterOrchestratorHandlerServer(ctx context.Context, mux *runtime.ServeMux, server OrchestratorServer) error

RegisterOrchestratorHandlerServer registers the http handlers for service Orchestrator to "mux". UnaryRPC :call OrchestratorServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterOrchestratorHandlerFromEndpoint instead.

func RegisterOrchestratorServer 

func RegisterOrchestratorServer(s grpc.ServiceRegistrar, srv OrchestratorServer)

Types

type AssessmentTool 

type AssessmentTool struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// a list of metrics that this tool can assess, referred by their ids
	AvailableMetrics []string `protobuf:"bytes,4,rep,name=available_metrics,json=availableMetrics,proto3" json:"available_metrics,omitempty"`
	// contains filtered or unexported fields
}

Represents an external tool or service that offers assessments according to certain metrics

func (*AssessmentTool) Descriptor deprecated 

func (*AssessmentTool) Descriptor() ([]byte, []int)

Deprecated: Use AssessmentTool.ProtoReflect.Descriptor instead.

func (*AssessmentTool) GetAvailableMetrics 

func (x *AssessmentTool) GetAvailableMetrics() []string

func (*AssessmentTool) GetDescription 

func (x *AssessmentTool) GetDescription() string

func (*AssessmentTool) GetId 

func (x *AssessmentTool) GetId() string

func (*AssessmentTool) GetName 

func (x *AssessmentTool) GetName() string

func (*AssessmentTool) ProtoMessage 

func (*AssessmentTool) ProtoMessage()

func (*AssessmentTool) ProtoReflect 

func (x *AssessmentTool) ProtoReflect() protoreflect.Message

func (*AssessmentTool) Reset 

func (x *AssessmentTool) Reset()

func (*AssessmentTool) String 

func (x *AssessmentTool) String() string

type CloudService added in v1.3.11 

type CloudService struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*CloudService) Descriptor deprecated added in v1.3.11 

func (*CloudService) Descriptor() ([]byte, []int)

Deprecated: Use CloudService.ProtoReflect.Descriptor instead.

func (*CloudService) GetDescription added in v1.3.11 

func (x *CloudService) GetDescription() string

func (*CloudService) GetId added in v1.3.11 

func (x *CloudService) GetId() string

func (*CloudService) GetName added in v1.3.11 

func (x *CloudService) GetName() string

func (*CloudService) ProtoMessage added in v1.3.11 

func (*CloudService) ProtoMessage()

func (*CloudService) ProtoReflect added in v1.3.11 

func (x *CloudService) ProtoReflect() protoreflect.Message

func (*CloudService) Reset added in v1.3.11 

func (x *CloudService) Reset()

func (*CloudService) String added in v1.3.11 

func (x *CloudService) String() string

type DeregisterAssessmentToolRequest 

type DeregisterAssessmentToolRequest struct {
	ToolId string `protobuf:"bytes,1,opt,name=tool_id,json=toolId,proto3" json:"tool_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeregisterAssessmentToolRequest) Descriptor deprecated 

func (*DeregisterAssessmentToolRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeregisterAssessmentToolRequest.ProtoReflect.Descriptor instead.

func (*DeregisterAssessmentToolRequest) GetToolId 

func (x *DeregisterAssessmentToolRequest) GetToolId() string

func (*DeregisterAssessmentToolRequest) ProtoMessage 

func (*DeregisterAssessmentToolRequest) ProtoMessage()

func (*DeregisterAssessmentToolRequest) ProtoReflect 

func (x *DeregisterAssessmentToolRequest) ProtoReflect() protoreflect.Message

func (*DeregisterAssessmentToolRequest) Reset 

func (x *DeregisterAssessmentToolRequest) Reset()

func (*DeregisterAssessmentToolRequest) String 

func (x *DeregisterAssessmentToolRequest) String() string

type GetAssessmentToolRequest 

type GetAssessmentToolRequest struct {
	ToolId string `protobuf:"bytes,1,opt,name=tool_id,json=toolId,proto3" json:"tool_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAssessmentToolRequest) Descriptor deprecated 

func (*GetAssessmentToolRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetAssessmentToolRequest.ProtoReflect.Descriptor instead.

func (*GetAssessmentToolRequest) GetToolId 

func (x *GetAssessmentToolRequest) GetToolId() string

func (*GetAssessmentToolRequest) ProtoMessage 

func (*GetAssessmentToolRequest) ProtoMessage()

func (*GetAssessmentToolRequest) ProtoReflect 

func (x *GetAssessmentToolRequest) ProtoReflect() protoreflect.Message

func (*GetAssessmentToolRequest) Reset 

func (x *GetAssessmentToolRequest) Reset()

func (*GetAssessmentToolRequest) String 

func (x *GetAssessmentToolRequest) String() string

type GetCloudServiceRequest added in v1.3.11 

type GetCloudServiceRequest struct {
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCloudServiceRequest) Descriptor deprecated added in v1.3.11 

func (*GetCloudServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetCloudServiceRequest.ProtoReflect.Descriptor instead.

func (*GetCloudServiceRequest) GetServiceId added in v1.3.11 

func (x *GetCloudServiceRequest) GetServiceId() string

func (*GetCloudServiceRequest) ProtoMessage added in v1.3.11 

func (*GetCloudServiceRequest) ProtoMessage()

func (*GetCloudServiceRequest) ProtoReflect added in v1.3.11 

func (x *GetCloudServiceRequest) ProtoReflect() protoreflect.Message

func (*GetCloudServiceRequest) Reset added in v1.3.11 

func (x *GetCloudServiceRequest) Reset()

func (*GetCloudServiceRequest) String added in v1.3.11 

func (x *GetCloudServiceRequest) String() string

type GetMetricConfigurationRequest added in v1.3.11 

type GetMetricConfigurationRequest struct {
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	MetricId  string `protobuf:"bytes,2,opt,name=metric_id,json=metricId,proto3" json:"metric_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMetricConfigurationRequest) Descriptor deprecated added in v1.3.11 

func (*GetMetricConfigurationRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetMetricConfigurationRequest.ProtoReflect.Descriptor instead.

func (*GetMetricConfigurationRequest) GetMetricId added in v1.3.11 

func (x *GetMetricConfigurationRequest) GetMetricId() string

func (*GetMetricConfigurationRequest) GetServiceId added in v1.3.11 

func (x *GetMetricConfigurationRequest) GetServiceId() string

func (*GetMetricConfigurationRequest) ProtoMessage added in v1.3.11 

func (*GetMetricConfigurationRequest) ProtoMessage()

func (*GetMetricConfigurationRequest) ProtoReflect added in v1.3.11 

func (x *GetMetricConfigurationRequest) ProtoReflect() protoreflect.Message

func (*GetMetricConfigurationRequest) Reset added in v1.3.11 

func (x *GetMetricConfigurationRequest) Reset()

func (*GetMetricConfigurationRequest) String added in v1.3.11 

func (x *GetMetricConfigurationRequest) String() string

type GetMetricsRequest 

type GetMetricsRequest struct {
	MetricId string `protobuf:"bytes,1,opt,name=metric_id,json=metricId,proto3" json:"metric_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMetricsRequest) Descriptor deprecated 

func (*GetMetricsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetMetricsRequest.ProtoReflect.Descriptor instead.

func (*GetMetricsRequest) GetMetricId 

func (x *GetMetricsRequest) GetMetricId() string

func (*GetMetricsRequest) ProtoMessage 

func (*GetMetricsRequest) ProtoMessage()

func (*GetMetricsRequest) ProtoReflect 

func (x *GetMetricsRequest) ProtoReflect() protoreflect.Message

func (*GetMetricsRequest) Reset 

func (x *GetMetricsRequest) Reset()

func (*GetMetricsRequest) String 

func (x *GetMetricsRequest) String() string

type ListAssessmentToolsRequest 

type ListAssessmentToolsRequest struct {

	// filter tools by metric id
	MetricId string `protobuf:"bytes,1,opt,name=metric_id,json=metricId,proto3" json:"metric_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAssessmentToolsRequest) Descriptor deprecated 

func (*ListAssessmentToolsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAssessmentToolsRequest.ProtoReflect.Descriptor instead.

func (*ListAssessmentToolsRequest) GetMetricId 

func (x *ListAssessmentToolsRequest) GetMetricId() string

func (*ListAssessmentToolsRequest) ProtoMessage 

func (*ListAssessmentToolsRequest) ProtoMessage()

func (*ListAssessmentToolsRequest) ProtoReflect 

func (x *ListAssessmentToolsRequest) ProtoReflect() protoreflect.Message

func (*ListAssessmentToolsRequest) Reset 

func (x *ListAssessmentToolsRequest) Reset()

func (*ListAssessmentToolsRequest) String 

func (x *ListAssessmentToolsRequest) String() string

type ListAssessmentToolsResponse 

type ListAssessmentToolsResponse struct {
	Tools []*AssessmentTool `protobuf:"bytes,1,rep,name=tools,proto3" json:"tools,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAssessmentToolsResponse) Descriptor deprecated 

func (*ListAssessmentToolsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListAssessmentToolsResponse.ProtoReflect.Descriptor instead.

func (*ListAssessmentToolsResponse) GetTools 

func (x *ListAssessmentToolsResponse) GetTools() []*AssessmentTool

func (*ListAssessmentToolsResponse) ProtoMessage 

func (*ListAssessmentToolsResponse) ProtoMessage()

func (*ListAssessmentToolsResponse) ProtoReflect 

func (x *ListAssessmentToolsResponse) ProtoReflect() protoreflect.Message

func (*ListAssessmentToolsResponse) Reset 

func (x *ListAssessmentToolsResponse) Reset()

func (*ListAssessmentToolsResponse) String 

func (x *ListAssessmentToolsResponse) String() string

type ListCloudServicesRequest added in v1.3.11 

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

func (*ListCloudServicesRequest) Descriptor deprecated added in v1.3.11 

func (*ListCloudServicesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListCloudServicesRequest.ProtoReflect.Descriptor instead.

func (*ListCloudServicesRequest) ProtoMessage added in v1.3.11 

func (*ListCloudServicesRequest) ProtoMessage()

func (*ListCloudServicesRequest) ProtoReflect added in v1.3.11 

func (x *ListCloudServicesRequest) ProtoReflect() protoreflect.Message

func (*ListCloudServicesRequest) Reset added in v1.3.11 

func (x *ListCloudServicesRequest) Reset()

func (*ListCloudServicesRequest) String added in v1.3.11 

func (x *ListCloudServicesRequest) String() string

type ListCloudServicesResponse added in v1.3.11 

type ListCloudServicesResponse struct {
	Services []*CloudService `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*ListCloudServicesResponse) Descriptor deprecated added in v1.3.11 

func (*ListCloudServicesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListCloudServicesResponse.ProtoReflect.Descriptor instead.

func (*ListCloudServicesResponse) GetServices added in v1.3.11 

func (x *ListCloudServicesResponse) GetServices() []*CloudService

func (*ListCloudServicesResponse) ProtoMessage added in v1.3.11 

func (*ListCloudServicesResponse) ProtoMessage()

func (*ListCloudServicesResponse) ProtoReflect added in v1.3.11 

func (x *ListCloudServicesResponse) ProtoReflect() protoreflect.Message

func (*ListCloudServicesResponse) Reset added in v1.3.11 

func (x *ListCloudServicesResponse) Reset()

func (*ListCloudServicesResponse) String added in v1.3.11 

func (x *ListCloudServicesResponse) String() string

type ListMetricConfigurationRequest added in v1.3.11 

type ListMetricConfigurationRequest struct {
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMetricConfigurationRequest) Descriptor deprecated added in v1.3.11 

func (*ListMetricConfigurationRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListMetricConfigurationRequest.ProtoReflect.Descriptor instead.

func (*ListMetricConfigurationRequest) GetServiceId added in v1.3.11 

func (x *ListMetricConfigurationRequest) GetServiceId() string

func (*ListMetricConfigurationRequest) ProtoMessage added in v1.3.11 

func (*ListMetricConfigurationRequest) ProtoMessage()

func (*ListMetricConfigurationRequest) ProtoReflect added in v1.3.11 

func (x *ListMetricConfigurationRequest) ProtoReflect() protoreflect.Message

func (*ListMetricConfigurationRequest) Reset added in v1.3.11 

func (x *ListMetricConfigurationRequest) Reset()

func (*ListMetricConfigurationRequest) String added in v1.3.11 

func (x *ListMetricConfigurationRequest) String() string

type ListMetricConfigurationResponse added in v1.3.11 

type ListMetricConfigurationResponse struct {

	// A map of metric configurations associated by their metric ID
	Configurations map[string]*assessment.MetricConfiguration `` /* 169-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListMetricConfigurationResponse) Descriptor deprecated added in v1.3.11 

func (*ListMetricConfigurationResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListMetricConfigurationResponse.ProtoReflect.Descriptor instead.

func (*ListMetricConfigurationResponse) GetConfigurations added in v1.3.11 

func (x *ListMetricConfigurationResponse) GetConfigurations() map[string]*assessment.MetricConfiguration

func (*ListMetricConfigurationResponse) ProtoMessage added in v1.3.11 

func (*ListMetricConfigurationResponse) ProtoMessage()

func (*ListMetricConfigurationResponse) ProtoReflect added in v1.3.11 

func (x *ListMetricConfigurationResponse) ProtoReflect() protoreflect.Message

func (*ListMetricConfigurationResponse) Reset added in v1.3.11 

func (x *ListMetricConfigurationResponse) Reset()

func (*ListMetricConfigurationResponse) String added in v1.3.11 

func (x *ListMetricConfigurationResponse) String() string

type ListMetricsRequest 

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

func (*ListMetricsRequest) Descriptor deprecated 

func (*ListMetricsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListMetricsRequest.ProtoReflect.Descriptor instead.

func (*ListMetricsRequest) ProtoMessage 

func (*ListMetricsRequest) ProtoMessage()

func (*ListMetricsRequest) ProtoReflect 

func (x *ListMetricsRequest) ProtoReflect() protoreflect.Message

func (*ListMetricsRequest) Reset 

func (x *ListMetricsRequest) Reset()

func (*ListMetricsRequest) String 

func (x *ListMetricsRequest) String() string

type ListMetricsResponse 

type ListMetricsResponse struct {
	Metrics []*assessment.Metric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMetricsResponse) Descriptor deprecated 

func (*ListMetricsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListMetricsResponse.ProtoReflect.Descriptor instead.

func (*ListMetricsResponse) GetMetrics 

func (x *ListMetricsResponse) GetMetrics() []*assessment.Metric

func (*ListMetricsResponse) ProtoMessage 

func (*ListMetricsResponse) ProtoMessage()

func (*ListMetricsResponse) ProtoReflect 

func (x *ListMetricsResponse) ProtoReflect() protoreflect.Message

func (*ListMetricsResponse) Reset 

func (x *ListMetricsResponse) Reset()

func (*ListMetricsResponse) String 

func (x *ListMetricsResponse) String() string

type OrchestratorClient 

type OrchestratorClient interface {
	// Registers the passed assessment tool
	RegisterAssessmentTool(ctx context.Context, in *RegisterAssessmentToolRequest, opts ...grpc.CallOption) (*AssessmentTool, error)
	// Lists all assessment tools assessing evidences for the metric given by the
	// passed metric id
	ListAssessmentTools(ctx context.Context, in *ListAssessmentToolsRequest, opts ...grpc.CallOption) (*ListAssessmentToolsResponse, error)
	// Returns assessment tool given by the passed tool id
	GetAssessmentTool(ctx context.Context, in *GetAssessmentToolRequest, opts ...grpc.CallOption) (*AssessmentTool, error)
	// Updates the assessment tool given by the passed id
	UpdateAssessmentTool(ctx context.Context, in *UpdateAssessmentToolRequest, opts ...grpc.CallOption) (*AssessmentTool, error)
	// Remove assessment tool with passed id from the list of active assessment
	// tools
	DeregisterAssessmentTool(ctx context.Context, in *DeregisterAssessmentToolRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Stores the assessment result provided by an assessment tool
	StoreAssessmentResult(ctx context.Context, in *StoreAssessmentResultRequest, opts ...grpc.CallOption) (*StoreAssessmentResultResponse, error)
	// Stores stream of assessment results provided by an assessment tool
	StoreAssessmentResults(ctx context.Context, opts ...grpc.CallOption) (Orchestrator_StoreAssessmentResultsClient, error)
	// List all metrics provided by the metric catalog
	ListMetrics(ctx context.Context, in *ListMetricsRequest, opts ...grpc.CallOption) (*ListMetricsResponse, error)
	// Returns the metric with the passed metric id
	GetMetric(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*assessment.Metric, error)
	// Registers a new target cloud service
	RegisterCloudService(ctx context.Context, in *RegisterCloudServiceRequest, opts ...grpc.CallOption) (*CloudService, error)
	// Registers a new target cloud service
	UpdateCloudService(ctx context.Context, in *UpdateCloudServiceRequest, opts ...grpc.CallOption) (*CloudService, error)
	// Retrieves a target cloud service
	GetCloudService(ctx context.Context, in *GetCloudServiceRequest, opts ...grpc.CallOption) (*CloudService, error)
	// Lists all target cloud services
	ListCloudServices(ctx context.Context, in *ListCloudServicesRequest, opts ...grpc.CallOption) (*ListCloudServicesResponse, error)
	// Removes a target cloud service
	RemoveCloudService(ctx context.Context, in *RemoveCloudServiceRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Retrieves a metric configuration for a specific service and metric ID
	GetMetricConfiguration(ctx context.Context, in *GetMetricConfigurationRequest, opts ...grpc.CallOption) (*assessment.MetricConfiguration, error)
	// Lists all a metric configurations for a specific service and metric ID
	ListMetricConfigurations(ctx context.Context, in *ListMetricConfigurationRequest, opts ...grpc.CallOption) (*ListMetricConfigurationResponse, error)
}

OrchestratorClient is the client API for Orchestrator service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOrchestratorClient 

func NewOrchestratorClient(cc grpc.ClientConnInterface) OrchestratorClient

type OrchestratorServer 

type OrchestratorServer interface {
	// Registers the passed assessment tool
	RegisterAssessmentTool(context.Context, *RegisterAssessmentToolRequest) (*AssessmentTool, error)
	// Lists all assessment tools assessing evidences for the metric given by the
	// passed metric id
	ListAssessmentTools(context.Context, *ListAssessmentToolsRequest) (*ListAssessmentToolsResponse, error)
	// Returns assessment tool given by the passed tool id
	GetAssessmentTool(context.Context, *GetAssessmentToolRequest) (*AssessmentTool, error)
	// Updates the assessment tool given by the passed id
	UpdateAssessmentTool(context.Context, *UpdateAssessmentToolRequest) (*AssessmentTool, error)
	// Remove assessment tool with passed id from the list of active assessment
	// tools
	DeregisterAssessmentTool(context.Context, *DeregisterAssessmentToolRequest) (*emptypb.Empty, error)
	// Stores the assessment result provided by an assessment tool
	StoreAssessmentResult(context.Context, *StoreAssessmentResultRequest) (*StoreAssessmentResultResponse, error)
	// Stores stream of assessment results provided by an assessment tool
	StoreAssessmentResults(Orchestrator_StoreAssessmentResultsServer) error
	// List all metrics provided by the metric catalog
	ListMetrics(context.Context, *ListMetricsRequest) (*ListMetricsResponse, error)
	// Returns the metric with the passed metric id
	GetMetric(context.Context, *GetMetricsRequest) (*assessment.Metric, error)
	// Registers a new target cloud service
	RegisterCloudService(context.Context, *RegisterCloudServiceRequest) (*CloudService, error)
	// Registers a new target cloud service
	UpdateCloudService(context.Context, *UpdateCloudServiceRequest) (*CloudService, error)
	// Retrieves a target cloud service
	GetCloudService(context.Context, *GetCloudServiceRequest) (*CloudService, error)
	// Lists all target cloud services
	ListCloudServices(context.Context, *ListCloudServicesRequest) (*ListCloudServicesResponse, error)
	// Removes a target cloud service
	RemoveCloudService(context.Context, *RemoveCloudServiceRequest) (*emptypb.Empty, error)
	// Retrieves a metric configuration for a specific service and metric ID
	GetMetricConfiguration(context.Context, *GetMetricConfigurationRequest) (*assessment.MetricConfiguration, error)
	// Lists all a metric configurations for a specific service and metric ID
	ListMetricConfigurations(context.Context, *ListMetricConfigurationRequest) (*ListMetricConfigurationResponse, error)
	// contains filtered or unexported methods
}

OrchestratorServer is the server API for Orchestrator service. All implementations must embed UnimplementedOrchestratorServer for forward compatibility

type Orchestrator_StoreAssessmentResultsClient added in v1.3.6 

type Orchestrator_StoreAssessmentResultsClient interface {
	Send(*assessment.AssessmentResult) error
	CloseAndRecv() (*emptypb.Empty, error)
	grpc.ClientStream
}

type Orchestrator_StoreAssessmentResultsServer added in v1.3.6 

type Orchestrator_StoreAssessmentResultsServer interface {
	SendAndClose(*emptypb.Empty) error
	Recv() (*assessment.AssessmentResult, error)
	grpc.ServerStream
}

type RegisterAssessmentToolRequest 

type RegisterAssessmentToolRequest struct {
	Tool *AssessmentTool `protobuf:"bytes,1,opt,name=tool,proto3" json:"tool,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterAssessmentToolRequest) Descriptor deprecated 

func (*RegisterAssessmentToolRequest) Descriptor() ([]byte, []int)

Deprecated: Use RegisterAssessmentToolRequest.ProtoReflect.Descriptor instead.

func (*RegisterAssessmentToolRequest) GetTool 

func (x *RegisterAssessmentToolRequest) GetTool() *AssessmentTool

func (*RegisterAssessmentToolRequest) ProtoMessage 

func (*RegisterAssessmentToolRequest) ProtoMessage()

func (*RegisterAssessmentToolRequest) ProtoReflect 

func (x *RegisterAssessmentToolRequest) ProtoReflect() protoreflect.Message

func (*RegisterAssessmentToolRequest) Reset 

func (x *RegisterAssessmentToolRequest) Reset()

func (*RegisterAssessmentToolRequest) String 

func (x *RegisterAssessmentToolRequest) String() string

type RegisterCloudServiceRequest added in v1.3.11 

type RegisterCloudServiceRequest struct {
	Service *CloudService `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterCloudServiceRequest) Descriptor deprecated added in v1.3.11 

func (*RegisterCloudServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use RegisterCloudServiceRequest.ProtoReflect.Descriptor instead.

func (*RegisterCloudServiceRequest) GetService added in v1.3.11 

func (x *RegisterCloudServiceRequest) GetService() *CloudService

func (*RegisterCloudServiceRequest) ProtoMessage added in v1.3.11 

func (*RegisterCloudServiceRequest) ProtoMessage()

func (*RegisterCloudServiceRequest) ProtoReflect added in v1.3.11 

func (x *RegisterCloudServiceRequest) ProtoReflect() protoreflect.Message

func (*RegisterCloudServiceRequest) Reset added in v1.3.11 

func (x *RegisterCloudServiceRequest) Reset()

func (*RegisterCloudServiceRequest) String added in v1.3.11 

func (x *RegisterCloudServiceRequest) String() string

type RemoveCloudServiceRequest added in v1.3.11 

type RemoveCloudServiceRequest struct {
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveCloudServiceRequest) Descriptor deprecated added in v1.3.11 

func (*RemoveCloudServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveCloudServiceRequest.ProtoReflect.Descriptor instead.

func (*RemoveCloudServiceRequest) GetServiceId added in v1.3.11 

func (x *RemoveCloudServiceRequest) GetServiceId() string

func (*RemoveCloudServiceRequest) ProtoMessage added in v1.3.11 

func (*RemoveCloudServiceRequest) ProtoMessage()

func (*RemoveCloudServiceRequest) ProtoReflect added in v1.3.11 

func (x *RemoveCloudServiceRequest) ProtoReflect() protoreflect.Message

func (*RemoveCloudServiceRequest) Reset added in v1.3.11 

func (x *RemoveCloudServiceRequest) Reset()

func (*RemoveCloudServiceRequest) String added in v1.3.11 

func (x *RemoveCloudServiceRequest) String() string

type StoreAssessmentResultRequest 

type StoreAssessmentResultRequest struct {
	Result *assessment.AssessmentResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreAssessmentResultRequest) Descriptor deprecated 

func (*StoreAssessmentResultRequest) Descriptor() ([]byte, []int)

Deprecated: Use StoreAssessmentResultRequest.ProtoReflect.Descriptor instead.

func (*StoreAssessmentResultRequest) GetResult 

func (x *StoreAssessmentResultRequest) GetResult() *assessment.AssessmentResult

func (*StoreAssessmentResultRequest) ProtoMessage 

func (*StoreAssessmentResultRequest) ProtoMessage()

func (*StoreAssessmentResultRequest) ProtoReflect 

func (x *StoreAssessmentResultRequest) ProtoReflect() protoreflect.Message

func (*StoreAssessmentResultRequest) Reset 

func (x *StoreAssessmentResultRequest) Reset()

func (*StoreAssessmentResultRequest) String 

func (x *StoreAssessmentResultRequest) String() string

type StoreAssessmentResultResponse added in v1.3.6 

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

func (*StoreAssessmentResultResponse) Descriptor deprecated added in v1.3.6 

func (*StoreAssessmentResultResponse) Descriptor() ([]byte, []int)

Deprecated: Use StoreAssessmentResultResponse.ProtoReflect.Descriptor instead.

func (*StoreAssessmentResultResponse) ProtoMessage added in v1.3.6 

func (*StoreAssessmentResultResponse) ProtoMessage()

func (*StoreAssessmentResultResponse) ProtoReflect added in v1.3.6 

func (x *StoreAssessmentResultResponse) ProtoReflect() protoreflect.Message

func (*StoreAssessmentResultResponse) Reset added in v1.3.6 

func (x *StoreAssessmentResultResponse) Reset()

func (*StoreAssessmentResultResponse) String added in v1.3.6 

func (x *StoreAssessmentResultResponse) String() string

type UnimplementedOrchestratorServer 

type UnimplementedOrchestratorServer struct {
}

UnimplementedOrchestratorServer must be embedded to have forward compatible implementations.

func (UnimplementedOrchestratorServer) DeregisterAssessmentTool 

func (UnimplementedOrchestratorServer) DeregisterAssessmentTool(context.Context, *DeregisterAssessmentToolRequest) (*emptypb.Empty, error)

func (UnimplementedOrchestratorServer) GetAssessmentTool 

func (UnimplementedOrchestratorServer) GetAssessmentTool(context.Context, *GetAssessmentToolRequest) (*AssessmentTool, error)

func (UnimplementedOrchestratorServer) GetCloudService added in v1.3.11 

func (UnimplementedOrchestratorServer) GetCloudService(context.Context, *GetCloudServiceRequest) (*CloudService, error)

func (UnimplementedOrchestratorServer) GetMetric 

func (UnimplementedOrchestratorServer) GetMetric(context.Context, *GetMetricsRequest) (*assessment.Metric, error)

func (UnimplementedOrchestratorServer) GetMetricConfiguration added in v1.3.11 

func (UnimplementedOrchestratorServer) GetMetricConfiguration(context.Context, *GetMetricConfigurationRequest) (*assessment.MetricConfiguration, error)

func (UnimplementedOrchestratorServer) ListAssessmentTools 

func (UnimplementedOrchestratorServer) ListAssessmentTools(context.Context, *ListAssessmentToolsRequest) (*ListAssessmentToolsResponse, error)

func (UnimplementedOrchestratorServer) ListCloudServices added in v1.3.11 

func (UnimplementedOrchestratorServer) ListCloudServices(context.Context, *ListCloudServicesRequest) (*ListCloudServicesResponse, error)

func (UnimplementedOrchestratorServer) ListMetricConfigurations added in v1.3.11 

func (UnimplementedOrchestratorServer) ListMetricConfigurations(context.Context, *ListMetricConfigurationRequest) (*ListMetricConfigurationResponse, error)

func (UnimplementedOrchestratorServer) ListMetrics 

func (UnimplementedOrchestratorServer) ListMetrics(context.Context, *ListMetricsRequest) (*ListMetricsResponse, error)

func (UnimplementedOrchestratorServer) RegisterAssessmentTool 

func (UnimplementedOrchestratorServer) RegisterAssessmentTool(context.Context, *RegisterAssessmentToolRequest) (*AssessmentTool, error)

func (UnimplementedOrchestratorServer) RegisterCloudService added in v1.3.11 

func (UnimplementedOrchestratorServer) RegisterCloudService(context.Context, *RegisterCloudServiceRequest) (*CloudService, error)

func (UnimplementedOrchestratorServer) RemoveCloudService added in v1.3.11 

func (UnimplementedOrchestratorServer) RemoveCloudService(context.Context, *RemoveCloudServiceRequest) (*emptypb.Empty, error)

func (UnimplementedOrchestratorServer) StoreAssessmentResult 

func (UnimplementedOrchestratorServer) StoreAssessmentResult(context.Context, *StoreAssessmentResultRequest) (*StoreAssessmentResultResponse, error)

func (UnimplementedOrchestratorServer) StoreAssessmentResults added in v1.3.6 

func (UnimplementedOrchestratorServer) StoreAssessmentResults(Orchestrator_StoreAssessmentResultsServer) error

func (UnimplementedOrchestratorServer) UpdateAssessmentTool 

func (UnimplementedOrchestratorServer) UpdateAssessmentTool(context.Context, *UpdateAssessmentToolRequest) (*AssessmentTool, error)

func (UnimplementedOrchestratorServer) UpdateCloudService added in v1.3.11 

func (UnimplementedOrchestratorServer) UpdateCloudService(context.Context, *UpdateCloudServiceRequest) (*CloudService, error)

type UnsafeOrchestratorServer 

type UnsafeOrchestratorServer interface {
	// contains filtered or unexported methods
}

UnsafeOrchestratorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OrchestratorServer will result in compilation errors.

type UpdateAssessmentToolRequest 

type UpdateAssessmentToolRequest struct {
	ToolId string          `protobuf:"bytes,1,opt,name=tool_id,json=toolId,proto3" json:"tool_id,omitempty"`
	Tool   *AssessmentTool `protobuf:"bytes,2,opt,name=tool,proto3" json:"tool,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateAssessmentToolRequest) Descriptor deprecated 

func (*UpdateAssessmentToolRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateAssessmentToolRequest.ProtoReflect.Descriptor instead.

func (*UpdateAssessmentToolRequest) GetTool 

func (x *UpdateAssessmentToolRequest) GetTool() *AssessmentTool

func (*UpdateAssessmentToolRequest) GetToolId 

func (x *UpdateAssessmentToolRequest) GetToolId() string

func (*UpdateAssessmentToolRequest) ProtoMessage 

func (*UpdateAssessmentToolRequest) ProtoMessage()

func (*UpdateAssessmentToolRequest) ProtoReflect 

func (x *UpdateAssessmentToolRequest) ProtoReflect() protoreflect.Message

func (*UpdateAssessmentToolRequest) Reset 

func (x *UpdateAssessmentToolRequest) Reset()

func (*UpdateAssessmentToolRequest) String 

func (x *UpdateAssessmentToolRequest) String() string

type UpdateCloudServiceRequest added in v1.3.11 

type UpdateCloudServiceRequest struct {
	ServiceId string        `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	Service   *CloudService `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateCloudServiceRequest) Descriptor deprecated added in v1.3.11 

func (*UpdateCloudServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateCloudServiceRequest.ProtoReflect.Descriptor instead.

func (*UpdateCloudServiceRequest) GetService added in v1.3.11 

func (x *UpdateCloudServiceRequest) GetService() *CloudService

func (*UpdateCloudServiceRequest) GetServiceId added in v1.3.11 

func (x *UpdateCloudServiceRequest) GetServiceId() string

func (*UpdateCloudServiceRequest) ProtoMessage added in v1.3.11 

func (*UpdateCloudServiceRequest) ProtoMessage()

func (*UpdateCloudServiceRequest) ProtoReflect added in v1.3.11 

func (x *UpdateCloudServiceRequest) ProtoReflect() protoreflect.Message

func (*UpdateCloudServiceRequest) Reset added in v1.3.11 

func (x *UpdateCloudServiceRequest) Reset()

func (*UpdateCloudServiceRequest) String added in v1.3.11 

func (x *UpdateCloudServiceRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.