Skip to content

Commit

Permalink
add func comments
Browse files Browse the repository at this point in the history
Signed-off-by: t-kikuc <[email protected]>
  • Loading branch information
t-kikuc committed Jan 8, 2025
1 parent b53f980 commit b2f9809
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions pkg/app/pipedv1/metadatastore/registry.go
Original file line number Diff line number Diff line change
Expand Up @@ -51,6 +51,7 @@ func (r *MetadataStoreRegistry) Delete(deploymentID string) {
delete(r.stores, deploymentID)
}

// GetStageMetadata implements the backend of PluginService.GetStageMetadata().
func (r *MetadataStoreRegistry) GetStageMetadata(ctx context.Context, req *service.GetStageMetadataRequest) (*service.GetStageMetadataResponse, error) {
mds, ok := r.stores[req.DeploymentId]
if !ok {
Expand All @@ -64,6 +65,7 @@ func (r *MetadataStoreRegistry) GetStageMetadata(ctx context.Context, req *servi
}, nil
}

// PutStageMetadata implements the backend of PluginService.PutStageMetadata().
func (r *MetadataStoreRegistry) PutStageMetadata(ctx context.Context, req *service.PutStageMetadataRequest) (*service.PutStageMetadataResponse, error) {
mds, ok := r.stores[req.DeploymentId]
if !ok {
Expand All @@ -78,6 +80,7 @@ func (r *MetadataStoreRegistry) PutStageMetadata(ctx context.Context, req *servi
return &service.PutStageMetadataResponse{}, nil
}

// PutStageMetadataMulti implements the backend of PluginService.PutStageMetadataMulti().
func (r *MetadataStoreRegistry) PutStageMetadataMulti(ctx context.Context, req *service.PutStageMetadataMultiRequest) (*service.PutStageMetadataMultiResponse, error) {
mds, ok := r.stores[req.DeploymentId]
if !ok {
Expand All @@ -92,6 +95,7 @@ func (r *MetadataStoreRegistry) PutStageMetadataMulti(ctx context.Context, req *
return &service.PutStageMetadataMultiResponse{}, nil
}

// GetDeploymentMetadata implements the backend of PluginService.GetDeploymentMetadata().
func (r *MetadataStoreRegistry) GetDeploymentMetadata(ctx context.Context, req *service.GetDeploymentMetadataRequest) (*service.GetDeploymentMetadataResponse, error) {
mds, ok := r.stores[req.DeploymentId]
if !ok {
Expand All @@ -105,6 +109,7 @@ func (r *MetadataStoreRegistry) GetDeploymentMetadata(ctx context.Context, req *
}, nil
}

// PutDeploymentMetadata implements the backend of PluginService.PutDeploymentMetadata().
func (r *MetadataStoreRegistry) PutDeploymentMetadata(ctx context.Context, req *service.PutDeploymentMetadataRequest) (*service.PutDeploymentMetadataResponse, error) {
mds, ok := r.stores[req.DeploymentId]
if !ok {
Expand All @@ -119,6 +124,7 @@ func (r *MetadataStoreRegistry) PutDeploymentMetadata(ctx context.Context, req *
return &service.PutDeploymentMetadataResponse{}, nil
}

// PutDeploymentMetadataMulti implements the backend of PluginService.PutDeploymentMetadataMulti().
func (r *MetadataStoreRegistry) PutDeploymentMetadataMulti(ctx context.Context, req *service.PutDeploymentMetadataMultiRequest) (*service.PutDeploymentMetadataMultiResponse, error) {
mds, ok := r.stores[req.DeploymentId]
if !ok {
Expand Down

0 comments on commit b2f9809

Please sign in to comment.