grpcservers

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClusterService 

type ClusterService struct {
	mrdspb.UnimplementedClustersServer
	// contains filtered or unexported fields
}

func NewClusterService 

func NewClusterService(ledger cluster.Ledger) *ClusterService

func (*ClusterService) Create 

func (s *ClusterService) Create(ctx context.Context, req *mrdspb.CreateClusterRequest) (*mrdspb.CreateClusterResponse, error)

Create creates a new Cluster

func (*ClusterService) Delete 

func (s *ClusterService) Delete(ctx context.Context, req *mrdspb.DeleteClusterRequest) (*mrdspb.DeleteClusterResponse, error)

Delete deletes a Cluster

func (*ClusterService) GetByID 

func (s *ClusterService) GetByID(ctx context.Context, req *mrdspb.GetClusterByIDRequest) (*mrdspb.GetClusterResponse, error)

GetByMetadata retrieves a Cluster by its metadata

func (*ClusterService) GetByName 

func (s *ClusterService) GetByName(ctx context.Context, req *mrdspb.GetClusterByNameRequest) (*mrdspb.GetClusterResponse, error)

GetByName retrieves a Cluster by its name

func (*ClusterService) List 

func (s *ClusterService) List(ctx context.Context, req *mrdspb.ListClusterRequest) (*mrdspb.ListClusterResponse, error)

List returns a list of Clusters that match the provided filters

func (*ClusterService) UpdateStatus 

func (s *ClusterService) UpdateStatus(ctx context.Context, req *mrdspb.UpdateClusterStatusRequest) (*mrdspb.UpdateClusterResponse, error)

UpdateState updates the state and message of an existing Cluster

type ComputeCapabilityService 

type ComputeCapabilityService struct {
	mrdspb.UnimplementedComputeCapabilitiesServer
	// contains filtered or unexported fields
}

func NewComputeCapabilityService 

func NewComputeCapabilityService(ledger computecapability.Ledger) *ComputeCapabilityService

func (*ComputeCapabilityService) Create 

func (s *ComputeCapabilityService) Create(ctx context.Context, req *mrdspb.CreateComputeCapabilityRequest) (*mrdspb.CreateComputeCapabilityResponse, error)

Create creates a new ComputeCapability

func (*ComputeCapabilityService) Delete 

func (s *ComputeCapabilityService) Delete(ctx context.Context, req *mrdspb.DeleteComputeCapabilityRequest) (*mrdspb.DeleteComputeCapabilityResponse, error)

Delete deletes a ComputeCapability

func (*ComputeCapabilityService) GetByID 

func (s *ComputeCapabilityService) GetByID(ctx context.Context, req *mrdspb.GetComputeCapabilityByIDRequest) (*mrdspb.GetComputeCapabilityResponse, error)

GetByName retrieves a ComputeCapability by its name

func (*ComputeCapabilityService) GetByName 

func (s *ComputeCapabilityService) GetByName(ctx context.Context, req *mrdspb.GetComputeCapabilityByNameRequest) (*mrdspb.GetComputeCapabilityResponse, error)

GetByName retrieves a ComputeCapability by its name

func (*ComputeCapabilityService) List 

func (s *ComputeCapabilityService) List(ctx context.Context, req *mrdspb.ListComputeCapabilityRequest) (*mrdspb.ListComputeCapabilityResponse, error)

List returns a list of ComputeCapabilitys that match the provided filters

func (*ComputeCapabilityService) UpdateStatus 

func (s *ComputeCapabilityService) UpdateStatus(ctx context.Context, req *mrdspb.UpdateComputeCapabilityStatusRequest) (*mrdspb.UpdateComputeCapabilityResponse, error)

UpdateState updates the state and message of an existing ComputeCapability

type DeploymentPlanService 

type DeploymentPlanService struct {
	mrdspb.UnimplementedDeploymentPlansServer
	// contains filtered or unexported fields
}

func NewDeploymentPlanService 

func NewDeploymentPlanService(ledger deploymentplan.Ledger) *DeploymentPlanService

func (*DeploymentPlanService) AddDeployment 

func (s *DeploymentPlanService) AddDeployment(ctx context.Context, req *mrdspb.AddDeploymentRequest) (*mrdspb.UpdateDeploymentPlanResponse, error)

AddDeployment adds a Deployment to an existing DeploymentPlan

func (*DeploymentPlanService) Create 

func (s *DeploymentPlanService) Create(ctx context.Context, req *mrdspb.CreateDeploymentPlanRequest) (*mrdspb.CreateDeploymentPlanResponse, error)

Create creates a new DeploymentPlan

func (*DeploymentPlanService) Delete 

func (s *DeploymentPlanService) Delete(ctx context.Context, req *mrdspb.DeleteDeploymentPlanRequest) (*mrdspb.DeleteDeploymentPlanResponse, error)

Delete deletes a DeploymentPlan by metadata

func (*DeploymentPlanService) GetByID 

func (s *DeploymentPlanService) GetByID(ctx context.Context, req *mrdspb.GetDeploymentPlanByIDRequest) (*mrdspb.GetDeploymentPlanResponse, error)

GetByID retrieves a DeploymentPlan by its ID

func (*DeploymentPlanService) GetByName 

func (s *DeploymentPlanService) GetByName(ctx context.Context, req *mrdspb.GetDeploymentPlanByNameRequest) (*mrdspb.GetDeploymentPlanResponse, error)

GetByName retrieves a DeploymentPlan by its name

func (*DeploymentPlanService) List 

func (s *DeploymentPlanService) List(ctx context.Context, req *mrdspb.ListDeploymentPlanRequest) (*mrdspb.ListDeploymentPlanResponse, error)

List returns a list of DeploymentPlans that match the provided filters

func (*DeploymentPlanService) UpdateDeploymentStatus 

func (s *DeploymentPlanService) UpdateDeploymentStatus(ctx context.Context, req *mrdspb.UpdateDeploymentStatusRequest) (*mrdspb.UpdateDeploymentPlanResponse, error)

UpdateDeploymentStatus updates the status of an existing Deployment

func (*DeploymentPlanService) UpdateStatus 

func (s *DeploymentPlanService) UpdateStatus(ctx context.Context, req *mrdspb.UpdateDeploymentPlanStatusRequest) (*mrdspb.UpdateDeploymentPlanResponse, error)

UpdateStatus updates the state of an existing DeploymentPlan

type MetaInstanceService 

type MetaInstanceService struct {
	mrdspb.UnimplementedMetaInstancesServer
	// contains filtered or unexported fields
}

func NewMetaInstanceService 

func NewMetaInstanceService(ledger metainstance.Ledger) *MetaInstanceService

func (*MetaInstanceService) AddOperation 

func (s *MetaInstanceService) AddOperation(ctx context.Context, req *mrdspb.AddOperationRequest) (*mrdspb.UpdateMetaInstanceResponse, error)

AddOperation adds an operation to a MetaInstance

func (*MetaInstanceService) AddRuntimeInstance 

func (s *MetaInstanceService) AddRuntimeInstance(ctx context.Context, req *mrdspb.AddRuntimeInstanceRequest) (*mrdspb.UpdateMetaInstanceResponse, error)

AddRuntimeInstance adds a runtime instance to a MetaInstance

func (*MetaInstanceService) Create 

func (s *MetaInstanceService) Create(ctx context.Context, req *mrdspb.CreateMetaInstanceRequest) (*mrdspb.CreateMetaInstanceResponse, error)

Create creates a new MetaInstance

func (*MetaInstanceService) Delete 

func (s *MetaInstanceService) Delete(ctx context.Context, req *mrdspb.DeleteMetaInstanceRequest) (*mrdspb.DeleteMetaInstanceResponse, error)

Delete deletes a MetaInstance

func (*MetaInstanceService) GetByID 

func (s *MetaInstanceService) GetByID(ctx context.Context, req *mrdspb.GetMetaInstanceByIDRequest) (*mrdspb.GetMetaInstanceResponse, error)

GetByID retrieves a MetaInstance by its ID

func (*MetaInstanceService) GetByName 

func (s *MetaInstanceService) GetByName(ctx context.Context, req *mrdspb.GetMetaInstanceByNameRequest) (*mrdspb.GetMetaInstanceResponse, error)

GetByName retrieves a MetaInstance by its name

func (*MetaInstanceService) List 

func (s *MetaInstanceService) List(ctx context.Context, req *mrdspb.ListMetaInstanceRequest) (*mrdspb.ListMetaInstanceResponse, error)

List returns a list of MetaInstances that match the provided filters

func (*MetaInstanceService) RemoveOperation 

func (s *MetaInstanceService) RemoveOperation(ctx context.Context, req *mrdspb.RemoveOperationRequest) (*mrdspb.UpdateMetaInstanceResponse, error)

RemoveOperation removes an operation from a MetaInstance

func (*MetaInstanceService) RemoveRuntimeInstance 

func (s *MetaInstanceService) RemoveRuntimeInstance(ctx context.Context, req *mrdspb.RemoveRuntimeInstanceRequest) (*mrdspb.UpdateMetaInstanceResponse, error)

RemoveRuntimeInstance removes a runtime instance from a MetaInstance

func (*MetaInstanceService) UpdateDeploymentID 

func (s *MetaInstanceService) UpdateDeploymentID(ctx context.Context, req *mrdspb.UpdateDeploymentIDRequest) (*mrdspb.UpdateMetaInstanceResponse, error)

UpdateDeploymentID updates the DeploymentID of an existing MetaInstance

func (*MetaInstanceService) UpdateOperationStatus 

func (s *MetaInstanceService) UpdateOperationStatus(ctx context.Context, req *mrdspb.UpdateOperationStatusRequest) (*mrdspb.UpdateMetaInstanceResponse, error)

UpdateOperationStatus updates the status of an operation on a MetaInstance

func (*MetaInstanceService) UpdateRuntimeActiveState 

func (s *MetaInstanceService) UpdateRuntimeActiveState(ctx context.Context, req *mrdspb.UpdateRuntimeActiveStateRequest) (*mrdspb.UpdateMetaInstanceResponse, error)

func (*MetaInstanceService) UpdateRuntimeStatus 

func (s *MetaInstanceService) UpdateRuntimeStatus(ctx context.Context, req *mrdspb.UpdateRuntimeStatusRequest) (*mrdspb.UpdateMetaInstanceResponse, error)

UpdateRuntimeStatus updates the status of a runtime instance on a MetaInstance

func (*MetaInstanceService) UpdateStatus 

func (s *MetaInstanceService) UpdateStatus(ctx context.Context, req *mrdspb.UpdateMetaInstanceStatusRequest) (*mrdspb.UpdateMetaInstanceResponse, error)

UpdateStatus updates the state and message of an existing MetaInstance

type NodeService 

type NodeService struct {
	mrdspb.UnimplementedNodesServer
	// contains filtered or unexported fields
}

func NewNodeService 

func NewNodeService(ledger node.Ledger) *NodeService

func (*NodeService) AddCapability 

func (s *NodeService) AddCapability(ctx context.Context, req *mrdspb.AddCapabilityRequest) (*mrdspb.UpdateNodeResponse, error)

func (*NodeService) AddDisruption 

func (s *NodeService) AddDisruption(ctx context.Context, req *mrdspb.AddDisruptionRequest) (*mrdspb.UpdateNodeResponse, error)

AddDisruption adds a disruption to a Node

func (*NodeService) Create 

func (s *NodeService) Create(ctx context.Context, req *mrdspb.CreateNodeRequest) (*mrdspb.CreateNodeResponse, error)

Create creates a new Node

func (*NodeService) Delete 

func (s *NodeService) Delete(ctx context.Context, req *mrdspb.DeleteNodeRequest) (*mrdspb.DeleteNodeResponse, error)

Delete deletes a Node

func (*NodeService) GetByID 

func (s *NodeService) GetByID(ctx context.Context, req *mrdspb.GetNodeByIDRequest) (*mrdspb.GetNodeResponse, error)

GetByID retrieves a Node by its ID

func (*NodeService) GetByName 

func (s *NodeService) GetByName(ctx context.Context, req *mrdspb.GetNodeByNameRequest) (*mrdspb.GetNodeResponse, error)

GetByName retrieves a Node by its name

func (*NodeService) List 

func (s *NodeService) List(ctx context.Context, req *mrdspb.ListNodeRequest) (*mrdspb.ListNodeResponse, error)

List returns a list of Nodes that match the provided filters

func (*NodeService) RemoveCapability 

func (s *NodeService) RemoveCapability(ctx context.Context, req *mrdspb.RemoveCapabilityRequest) (*mrdspb.UpdateNodeResponse, error)

func (*NodeService) RemoveDisruption 

func (s *NodeService) RemoveDisruption(ctx context.Context, req *mrdspb.RemoveDisruptionRequest) (*mrdspb.UpdateNodeResponse, error)

func (*NodeService) UpdateDisruptionStatus 

func (s *NodeService) UpdateDisruptionStatus(ctx context.Context, req *mrdspb.UpdateDisruptionStatusRequest) (*mrdspb.UpdateNodeResponse, error)

UpdateDisruptionStatus updates the status of a disruption on a Node

func (*NodeService) UpdateStatus 

func (s *NodeService) UpdateStatus(ctx context.Context, req *mrdspb.UpdateNodeStatusRequest) (*mrdspb.UpdateNodeResponse, error)

UpdateState updates the state and message of an existing Node

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.