Documentation ¶
Overview ¶
Package orchestrator is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterOrchestratorHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterOrchestratorHandlerClient(ctx context.Context, mux *runtime.ServeMux, client OrchestratorClient) error
- func RegisterOrchestratorHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterOrchestratorHandlerServer(ctx context.Context, mux *runtime.ServeMux, server OrchestratorServer) error
- func RegisterOrchestratorServer(s grpc.ServiceRegistrar, srv OrchestratorServer)
- type AssessmentResult
- func (*AssessmentResult) Descriptor() ([]byte, []int)deprecated
- func (x *AssessmentResult) GetEvidence() *assessment.Evidence
- func (x *AssessmentResult) GetId() string
- func (x *AssessmentResult) GetMetricId() string
- func (x *AssessmentResult) GetResult() AssessmentResult_ComplianceStatus
- func (x *AssessmentResult) GetTargetValue() string
- func (*AssessmentResult) ProtoMessage()
- func (x *AssessmentResult) ProtoReflect() protoreflect.Message
- func (x *AssessmentResult) Reset()
- func (x *AssessmentResult) String() string
- type AssessmentResult_ComplianceStatus
- func (AssessmentResult_ComplianceStatus) Descriptor() protoreflect.EnumDescriptor
- func (x AssessmentResult_ComplianceStatus) Enum() *AssessmentResult_ComplianceStatus
- func (AssessmentResult_ComplianceStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x AssessmentResult_ComplianceStatus) Number() protoreflect.EnumNumber
- func (x AssessmentResult_ComplianceStatus) String() string
- func (AssessmentResult_ComplianceStatus) Type() protoreflect.EnumType
- type AssessmentTool
- func (*AssessmentTool) Descriptor() ([]byte, []int)deprecated
- func (x *AssessmentTool) GetAvailableMetrics() []string
- func (x *AssessmentTool) GetDescription() string
- func (x *AssessmentTool) GetId() string
- func (x *AssessmentTool) GetName() string
- func (*AssessmentTool) ProtoMessage()
- func (x *AssessmentTool) ProtoReflect() protoreflect.Message
- func (x *AssessmentTool) Reset()
- func (x *AssessmentTool) String() string
- type DeregisterAssessmentToolRequest
- func (*DeregisterAssessmentToolRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeregisterAssessmentToolRequest) GetToolId() string
- func (*DeregisterAssessmentToolRequest) ProtoMessage()
- func (x *DeregisterAssessmentToolRequest) ProtoReflect() protoreflect.Message
- func (x *DeregisterAssessmentToolRequest) Reset()
- func (x *DeregisterAssessmentToolRequest) String() string
- type GetAssessmentToolRequest
- func (*GetAssessmentToolRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetAssessmentToolRequest) GetToolId() string
- func (*GetAssessmentToolRequest) ProtoMessage()
- func (x *GetAssessmentToolRequest) ProtoReflect() protoreflect.Message
- func (x *GetAssessmentToolRequest) Reset()
- func (x *GetAssessmentToolRequest) String() string
- type GetMetricsRequest
- type ListAssessmentToolsRequest
- func (*ListAssessmentToolsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListAssessmentToolsRequest) GetMetricId() string
- func (*ListAssessmentToolsRequest) ProtoMessage()
- func (x *ListAssessmentToolsRequest) ProtoReflect() protoreflect.Message
- func (x *ListAssessmentToolsRequest) Reset()
- func (x *ListAssessmentToolsRequest) String() string
- type ListAssessmentToolsResponse
- func (*ListAssessmentToolsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListAssessmentToolsResponse) GetTools() []*AssessmentTool
- func (*ListAssessmentToolsResponse) ProtoMessage()
- func (x *ListAssessmentToolsResponse) ProtoReflect() protoreflect.Message
- func (x *ListAssessmentToolsResponse) Reset()
- func (x *ListAssessmentToolsResponse) String() string
- type ListMetricsRequest
- type ListMetricsResponse
- func (*ListMetricsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListMetricsResponse) GetMetrics() []*assessment.Metric
- func (*ListMetricsResponse) ProtoMessage()
- func (x *ListMetricsResponse) ProtoReflect() protoreflect.Message
- func (x *ListMetricsResponse) Reset()
- func (x *ListMetricsResponse) String() string
- type OrchestratorClient
- type OrchestratorServer
- type Orchestrator_StreamAssessmentResultsClient
- type Orchestrator_StreamAssessmentResultsServer
- type RegisterAssessmentToolRequest
- func (*RegisterAssessmentToolRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterAssessmentToolRequest) GetTool() *AssessmentTool
- func (*RegisterAssessmentToolRequest) ProtoMessage()
- func (x *RegisterAssessmentToolRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterAssessmentToolRequest) Reset()
- func (x *RegisterAssessmentToolRequest) String() string
- type StoreAssessmentResultRequest
- func (*StoreAssessmentResultRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StoreAssessmentResultRequest) GetResult() *AssessmentResult
- func (*StoreAssessmentResultRequest) ProtoMessage()
- func (x *StoreAssessmentResultRequest) ProtoReflect() protoreflect.Message
- func (x *StoreAssessmentResultRequest) Reset()
- func (x *StoreAssessmentResultRequest) String() string
- type UnimplementedOrchestratorServer
- func (UnimplementedOrchestratorServer) DeregisterAssessmentTool(context.Context, *DeregisterAssessmentToolRequest) (*emptypb.Empty, error)
- func (UnimplementedOrchestratorServer) GetAssessmentTool(context.Context, *GetAssessmentToolRequest) (*AssessmentTool, error)
- func (UnimplementedOrchestratorServer) GetMetric(context.Context, *GetMetricsRequest) (*assessment.Metric, error)
- func (UnimplementedOrchestratorServer) ListAssessmentTools(context.Context, *ListAssessmentToolsRequest) (*ListAssessmentToolsResponse, error)
- func (UnimplementedOrchestratorServer) ListMetrics(context.Context, *ListMetricsRequest) (*ListMetricsResponse, error)
- func (UnimplementedOrchestratorServer) RegisterAssessmentTool(context.Context, *RegisterAssessmentToolRequest) (*AssessmentTool, error)
- func (UnimplementedOrchestratorServer) StoreAssessmentResult(context.Context, *StoreAssessmentResultRequest) (*emptypb.Empty, error)
- func (UnimplementedOrchestratorServer) StreamAssessmentResults(Orchestrator_StreamAssessmentResultsServer) error
- func (UnimplementedOrchestratorServer) UpdateAssessmentTool(context.Context, *UpdateAssessmentToolRequest) (*AssessmentTool, error)
- type UnsafeOrchestratorServer
- type UpdateAssessmentToolRequest
- func (*UpdateAssessmentToolRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateAssessmentToolRequest) GetTool() *AssessmentTool
- func (x *UpdateAssessmentToolRequest) GetToolId() string
- func (*UpdateAssessmentToolRequest) ProtoMessage()
- func (x *UpdateAssessmentToolRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateAssessmentToolRequest) Reset()
- func (x *UpdateAssessmentToolRequest) String() string
Constants ¶
This section is empty.
Variables ¶
var ( AssessmentResult_ComplianceStatus_name = map[int32]string{ 0: "COMPLIANT", 1: "NON_COMPLIANT", } AssessmentResult_ComplianceStatus_value = map[string]int32{ "COMPLIANT": 0, "NON_COMPLIANT": 1, } )
Enum value maps for AssessmentResult_ComplianceStatus.
var File_orchestrator_proto protoreflect.FileDescriptor
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, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamAssessmentResults", Handler: _Orchestrator_StreamAssessmentResults_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 AssessmentResult ¶
type AssessmentResult struct { // the ID in a uuid format Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // the ID of the metric it refers to MetricId string `protobuf:"bytes,2,opt,name=metric_id,json=metricId,proto3" json:"metric_id,omitempty"` Result AssessmentResult_ComplianceStatus `protobuf:"varint,3,opt,name=result,proto3,enum=clouditor.AssessmentResult_ComplianceStatus" json:"result,omitempty"` TargetValue string `protobuf:"bytes,4,opt,name=target_value,json=targetValue,proto3" json:"target_value,omitempty"` Evidence *assessment.Evidence `protobuf:"bytes,5,opt,name=evidence,proto3" json:"evidence,omitempty"` // contains filtered or unexported fields }
func (*AssessmentResult) Descriptor
deprecated
func (*AssessmentResult) Descriptor() ([]byte, []int)
Deprecated: Use AssessmentResult.ProtoReflect.Descriptor instead.
func (*AssessmentResult) GetEvidence ¶
func (x *AssessmentResult) GetEvidence() *assessment.Evidence
func (*AssessmentResult) GetId ¶
func (x *AssessmentResult) GetId() string
func (*AssessmentResult) GetMetricId ¶
func (x *AssessmentResult) GetMetricId() string
func (*AssessmentResult) GetResult ¶
func (x *AssessmentResult) GetResult() AssessmentResult_ComplianceStatus
func (*AssessmentResult) GetTargetValue ¶
func (x *AssessmentResult) GetTargetValue() string
func (*AssessmentResult) ProtoMessage ¶
func (*AssessmentResult) ProtoMessage()
func (*AssessmentResult) ProtoReflect ¶
func (x *AssessmentResult) ProtoReflect() protoreflect.Message
func (*AssessmentResult) Reset ¶
func (x *AssessmentResult) Reset()
func (*AssessmentResult) String ¶
func (x *AssessmentResult) String() string
type AssessmentResult_ComplianceStatus ¶
type AssessmentResult_ComplianceStatus int32
const ( AssessmentResult_COMPLIANT AssessmentResult_ComplianceStatus = 0 AssessmentResult_NON_COMPLIANT AssessmentResult_ComplianceStatus = 1 )
func (AssessmentResult_ComplianceStatus) Descriptor ¶
func (AssessmentResult_ComplianceStatus) Descriptor() protoreflect.EnumDescriptor
func (AssessmentResult_ComplianceStatus) Enum ¶
func (x AssessmentResult_ComplianceStatus) Enum() *AssessmentResult_ComplianceStatus
func (AssessmentResult_ComplianceStatus) EnumDescriptor
deprecated
func (AssessmentResult_ComplianceStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use AssessmentResult_ComplianceStatus.Descriptor instead.
func (AssessmentResult_ComplianceStatus) Number ¶
func (x AssessmentResult_ComplianceStatus) Number() protoreflect.EnumNumber
func (AssessmentResult_ComplianceStatus) String ¶
func (x AssessmentResult_ComplianceStatus) String() string
func (AssessmentResult_ComplianceStatus) Type ¶
func (AssessmentResult_ComplianceStatus) Type() protoreflect.EnumType
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 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 GetMetricsRequest ¶
type GetMetricsRequest struct { MetricId int32 `protobuf:"varint,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() int32
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 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 { RegisterAssessmentTool(ctx context.Context, in *RegisterAssessmentToolRequest, opts ...grpc.CallOption) (*AssessmentTool, error) ListAssessmentTools(ctx context.Context, in *ListAssessmentToolsRequest, opts ...grpc.CallOption) (*ListAssessmentToolsResponse, error) GetAssessmentTool(ctx context.Context, in *GetAssessmentToolRequest, opts ...grpc.CallOption) (*AssessmentTool, error) UpdateAssessmentTool(ctx context.Context, in *UpdateAssessmentToolRequest, opts ...grpc.CallOption) (*AssessmentTool, error) DeregisterAssessmentTool(ctx context.Context, in *DeregisterAssessmentToolRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) StoreAssessmentResult(ctx context.Context, in *StoreAssessmentResultRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) StreamAssessmentResults(ctx context.Context, opts ...grpc.CallOption) (Orchestrator_StreamAssessmentResultsClient, error) ListMetrics(ctx context.Context, in *ListMetricsRequest, opts ...grpc.CallOption) (*ListMetricsResponse, error) GetMetric(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*assessment.Metric, 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 { RegisterAssessmentTool(context.Context, *RegisterAssessmentToolRequest) (*AssessmentTool, error) ListAssessmentTools(context.Context, *ListAssessmentToolsRequest) (*ListAssessmentToolsResponse, error) GetAssessmentTool(context.Context, *GetAssessmentToolRequest) (*AssessmentTool, error) UpdateAssessmentTool(context.Context, *UpdateAssessmentToolRequest) (*AssessmentTool, error) DeregisterAssessmentTool(context.Context, *DeregisterAssessmentToolRequest) (*emptypb.Empty, error) StoreAssessmentResult(context.Context, *StoreAssessmentResultRequest) (*emptypb.Empty, error) StreamAssessmentResults(Orchestrator_StreamAssessmentResultsServer) error ListMetrics(context.Context, *ListMetricsRequest) (*ListMetricsResponse, error) GetMetric(context.Context, *GetMetricsRequest) (*assessment.Metric, error) // contains filtered or unexported methods }
OrchestratorServer is the server API for Orchestrator service. All implementations must embed UnimplementedOrchestratorServer for forward compatibility
type Orchestrator_StreamAssessmentResultsClient ¶
type Orchestrator_StreamAssessmentResultsClient interface { Send(*AssessmentResult) error CloseAndRecv() (*emptypb.Empty, error) grpc.ClientStream }
type Orchestrator_StreamAssessmentResultsServer ¶
type Orchestrator_StreamAssessmentResultsServer interface { SendAndClose(*emptypb.Empty) error Recv() (*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 StoreAssessmentResultRequest ¶
type StoreAssessmentResultRequest struct { Result *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() *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 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) GetMetric ¶
func (UnimplementedOrchestratorServer) GetMetric(context.Context, *GetMetricsRequest) (*assessment.Metric, error)
func (UnimplementedOrchestratorServer) ListAssessmentTools ¶
func (UnimplementedOrchestratorServer) ListAssessmentTools(context.Context, *ListAssessmentToolsRequest) (*ListAssessmentToolsResponse, 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) StoreAssessmentResult ¶
func (UnimplementedOrchestratorServer) StoreAssessmentResult(context.Context, *StoreAssessmentResultRequest) (*emptypb.Empty, error)
func (UnimplementedOrchestratorServer) StreamAssessmentResults ¶
func (UnimplementedOrchestratorServer) StreamAssessmentResults(Orchestrator_StreamAssessmentResultsServer) error
func (UnimplementedOrchestratorServer) UpdateAssessmentTool ¶
func (UnimplementedOrchestratorServer) UpdateAssessmentTool(context.Context, *UpdateAssessmentToolRequest) (*AssessmentTool, 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