service

package
v0.4.2 Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2023 License: Apache-2.0 Imports: 26 Imported by: 0

README

Service

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DeploymentRuntimeFilterRules = map[string]map[string]selector.FieldSelector{
		"projects_ref.in": {
			selector.EqualOperator: selector.NewStringSelector("Spec.ProjectsRef.In", selector.In),
		},
		"manifest_source.code_repo": {
			selector.EqualOperator: selector.NewStringSelector("Spec.ManifestSource.CodeRepo", selector.In),
		},
		"destination": {
			selector.EqualOperator: selector.NewStringSelector("Spec.Destination", selector.In),
		},
	}
)
View Source 
var (
	// Data rules for filtering list cluster api.
	ProductFilterRules = map[string]map[string]selector.FieldSelector{
		"product_name": {
			selector.EqualOperator: selector.NewStringSelector("Name", selector.In),
		},
	}
)
View Source 
var (
	// Data rules for filtering list cluster api.
	ProjectFilterRules = map[string]map[string]selector.FieldSelector{
		"project_name": {
			selector.EqualOperator: selector.NewStringSelector("Name", selector.In),
		},
	}
)
View Source 
var (
	ProjectPipelineRuntimeFilterRules = map[string]map[string]selector.FieldSelector{
		"project_name": {
			selector.EqualOperator: selector.NewStringSelector("Name", selector.In),
		},
		"pipeline_triggers.pipeline": {
			selector.EqualOperator: selector.NewStringSelector("Spec.PipelineTriggers.Pipeline", selector.In),
		},
		"destination": {
			selector.EqualOperator: selector.NewStringSelector("Spec.Destination", selector.In),
		},
		"pipeline_source": {
			selector.EqualOperator: selector.NewStringSelector("Spec.PipelineSource", selector.In),
		},
		"project": {
			selector.EqualOperator: selector.NewStringSelector("Spec.Project", selector.In),
		},
	}
)
View Source 
var ProviderSet = wire.NewSet(NewProjectPipelineRuntimeService, NewDeploymentruntimeService, NewCodeRepoService, NewProductService, NewProjectService, NewEnvironmentService, NewClusterService, NewCodeRepoBindingService)

ProviderSet is service providers.

Functions

func NewReplay added in v0.4.2 

func NewReplay(projectPipelineRuntime *resourcev1alpha1.ProjectPipelineRuntime) (*projectpipelineruntimev1.GetReply, error)

Types

type ClusterService 

type ClusterService struct {
	clusterv1.UnimplementedClusterServer
	// contains filtered or unexported fields
}

func NewClusterService 

func NewClusterService(cluster *biz.ClusterUsecase, nautesConfigs *nautesconfigs.Config) (*ClusterService, error)

func (*ClusterService) DeleteCluster 

func (s *ClusterService) DeleteCluster(ctx context.Context, req *clusterv1.DeleteRequest) (*clusterv1.DeleteReply, error)

func (*ClusterService) GetCluster 

func (s *ClusterService) GetCluster(ctx context.Context, req *clusterv1.GetRequest) (*clusterv1.GetReply, error)

func (*ClusterService) ListClusters 

func (s *ClusterService) ListClusters(ctx context.Context, req *clusterv1.ListsRequest) (*clusterv1.ListsReply, error)

func (*ClusterService) SaveCluster 

func (s *ClusterService) SaveCluster(ctx context.Context, req *clusterv1.SaveRequest) (*clusterv1.SaveReply, error)

type CodeRepoBindingService 

type CodeRepoBindingService struct {
	coderepobindingv1.UnimplementedCodeRepoBindingServer
	// contains filtered or unexported fields
}

func NewCodeRepoBindingService 

func NewCodeRepoBindingService(codeRepoBindingUsecase *biz.CodeRepoBindingUsecase, codeRepo biz.CodeRepo) *CodeRepoBindingService

func (*CodeRepoBindingService) ConvertProductAndRepoName 

func (s *CodeRepoBindingService) ConvertProductAndRepoName(ctx context.Context, resource *resourcev1alpha1.CodeRepoBinding) error

func (*CodeRepoBindingService) CovertCodeRepoBindingValueToReply 

func (s *CodeRepoBindingService) CovertCodeRepoBindingValueToReply(codeRepoBinding *resourcev1alpha1.CodeRepoBinding) *coderepobindingv1.GetReply

func (*CodeRepoBindingService) DeleteCodeRepoBinding 

func (s *CodeRepoBindingService) DeleteCodeRepoBinding(ctx context.Context, req *coderepobindingv1.DeleteRequest) (*coderepobindingv1.DeleteReply, error)

func (*CodeRepoBindingService) GetCodeRepoBinding 

func (s *CodeRepoBindingService) GetCodeRepoBinding(ctx context.Context, req *coderepobindingv1.GetRequest) (*coderepobindingv1.GetReply, error)

func (*CodeRepoBindingService) ListCodeRepoBindings 

func (s *CodeRepoBindingService) ListCodeRepoBindings(ctx context.Context, req *coderepobindingv1.ListsRequest) (*coderepobindingv1.ListsReply, error)

func (*CodeRepoBindingService) SaveCodeRepoBinding 

func (s *CodeRepoBindingService) SaveCodeRepoBinding(ctx context.Context, req *coderepobindingv1.SaveRequest) (*coderepobindingv1.SaveReply, error)

type CodeRepoService 

type CodeRepoService struct {
	coderepov1.UnimplementedCodeRepoServer
	// contains filtered or unexported fields
}

func NewCodeRepoService 

func NewCodeRepoService(codeRepo *biz.CodeRepoUsecase, configs *nautesconfigs.Config) *CodeRepoService

func (*CodeRepoService) DeleteCodeRepo 

func (s *CodeRepoService) DeleteCodeRepo(ctx context.Context, req *coderepov1.DeleteRequest) (*coderepov1.DeleteReply, error)

func (*CodeRepoService) GetCodeRepo 

func (s *CodeRepoService) GetCodeRepo(ctx context.Context, req *coderepov1.GetRequest) (*coderepov1.GetReply, error)

func (*CodeRepoService) ListCodeRepos 

func (s *CodeRepoService) ListCodeRepos(ctx context.Context, req *coderepov1.ListsRequest) (*coderepov1.ListsReply, error)

func (*CodeRepoService) SaveCodeRepo 

func (s *CodeRepoService) SaveCodeRepo(ctx context.Context, req *coderepov1.SaveRequest) (*coderepov1.SaveReply, error)

type DeploymentruntimeService 

type DeploymentruntimeService struct {
	deploymentruntimev1.UnimplementedDeploymentruntimeServer
	// contains filtered or unexported fields
}

func NewDeploymentruntimeService 

func NewDeploymentruntimeService(deploymentRuntime *biz.DeploymentRuntimeUsecase, codeRepo biz.CodeRepo) *DeploymentruntimeService

func (*DeploymentruntimeService) CovertDeploymentRuntimeValueToReply 

func (s *DeploymentruntimeService) CovertDeploymentRuntimeValueToReply(runtime *resourcev1alpha1.DeploymentRuntime) *deploymentruntimev1.GetReply

func (*DeploymentruntimeService) DeleteDeploymentRuntime 

func (s *DeploymentruntimeService) DeleteDeploymentRuntime(ctx context.Context, req *deploymentruntimev1.DeleteRequest) (*deploymentruntimev1.DeleteReply, error)

func (*DeploymentruntimeService) GetDeploymentRuntime 

func (s *DeploymentruntimeService) GetDeploymentRuntime(ctx context.Context, req *deploymentruntimev1.GetRequest) (*deploymentruntimev1.GetReply, error)

func (*DeploymentruntimeService) ListDeploymentRuntimes 

func (s *DeploymentruntimeService) ListDeploymentRuntimes(ctx context.Context, req *deploymentruntimev1.ListsRequest) (*deploymentruntimev1.ListsReply, error)

func (*DeploymentruntimeService) SaveDeploymentRuntime 

func (s *DeploymentruntimeService) SaveDeploymentRuntime(ctx context.Context, req *deploymentruntimev1.SaveRequest) (*deploymentruntimev1.SaveReply, error)

type EnvironmentService 

type EnvironmentService struct {
	environmentv1.UnimplementedEnvironmentServer
	// contains filtered or unexported fields
}

func NewEnvironmentService 

func NewEnvironmentService(environment *biz.EnvironmentUsecase) *EnvironmentService

func (*EnvironmentService) DeleteEnvironment 

func (s *EnvironmentService) DeleteEnvironment(ctx context.Context, req *environmentv1.DeleteRequest) (*environmentv1.DeleteReply, error)

func (*EnvironmentService) GetEnvironment 

func (s *EnvironmentService) GetEnvironment(ctx context.Context, req *environmentv1.GetRequest) (*environmentv1.GetReply, error)

func (*EnvironmentService) ListEnvironments 

func (s *EnvironmentService) ListEnvironments(ctx context.Context, req *environmentv1.ListsRequest) (*environmentv1.ListsReply, error)

func (*EnvironmentService) NewGetReply added in v0.4.2 

func (s *EnvironmentService) NewGetReply(env *resourcev1alpha1.Environment) *environmentv1.GetReply

func (*EnvironmentService) SaveEnvironment 

func (s *EnvironmentService) SaveEnvironment(ctx context.Context, req *environmentv1.SaveRequest) (*environmentv1.SaveReply, error)

type ProductService 

type ProductService struct {
	productv1.UnimplementedProductServer
	// contains filtered or unexported fields
}

func NewProductService 

func NewProductService(product *biz.ProductUsecase, configs *nautesconfigs.Config) *ProductService

func (*ProductService) DeleteProduct 

func (s *ProductService) DeleteProduct(ctx context.Context, req *productv1.DeleteProductRequest) (*productv1.DeleteProductReply, error)

func (*ProductService) GetProduct 

func (s *ProductService) GetProduct(ctx context.Context, req *productv1.GetProductRequest) (*productv1.GetProductReply, error)

func (*ProductService) ListProducts 

func (s *ProductService) ListProducts(ctx context.Context, req *productv1.ListProductsRequest) (*productv1.ListProductsReply, error)

func (*ProductService) SaveProduct 

func (s *ProductService) SaveProduct(ctx context.Context, req *productv1.SaveProductRequest) (*productv1.SaveProductReply, error)

type ProjectPipelineRuntimeService 

type ProjectPipelineRuntimeService struct {
	projectpipelineruntimev1.UnimplementedProjectPipelineRuntimeServer
	// contains filtered or unexported fields
}

func NewProjectPipelineRuntimeService 

func NewProjectPipelineRuntimeService(projectPipelineRuntime *biz.ProjectPipelineRuntimeUsecase, codeRepo biz.CodeRepo) *ProjectPipelineRuntimeService

func (*ProjectPipelineRuntimeService) DeleteProjectPipelineRuntime 

func (s *ProjectPipelineRuntimeService) DeleteProjectPipelineRuntime(ctx context.Context, req *projectpipelineruntimev1.DeleteRequest) (*projectpipelineruntimev1.DeleteReply, error)

func (*ProjectPipelineRuntimeService) GetProjectPipelineRuntime 

func (s *ProjectPipelineRuntimeService) GetProjectPipelineRuntime(ctx context.Context, req *projectpipelineruntimev1.GetRequest) (*projectpipelineruntimev1.GetReply, error)

func (*ProjectPipelineRuntimeService) ListProjectPipelineRuntimes 

func (s *ProjectPipelineRuntimeService) ListProjectPipelineRuntimes(ctx context.Context, req *projectpipelineruntimev1.ListsRequest) (*projectpipelineruntimev1.ListsReply, error)

func (*ProjectPipelineRuntimeService) NewProjectPipelineRuntimeData added in v0.4.2 

func (s *ProjectPipelineRuntimeService) NewProjectPipelineRuntimeData(req *projectpipelineruntimev1.SaveRequest) *biz.ProjectPipelineRuntimeData

func (*ProjectPipelineRuntimeService) SaveProjectPipelineRuntime 

func (s *ProjectPipelineRuntimeService) SaveProjectPipelineRuntime(ctx context.Context, req *projectpipelineruntimev1.SaveRequest) (*projectpipelineruntimev1.SaveReply, error)

type ProjectService 

type ProjectService struct {
	projectv1.UnimplementedProjectServer
	// contains filtered or unexported fields
}

func NewProjectService 

func NewProjectService(project *biz.ProjectUsecase) *ProjectService

func (*ProjectService) CovertCodeRepoValueToReply 

func (s *ProjectService) CovertCodeRepoValueToReply(project *resourcev1alpha1.Project) *projectv1.GetReply

func (*ProjectService) DeleteProject 

func (s *ProjectService) DeleteProject(ctx context.Context, req *projectv1.DeleteRequest) (*projectv1.DeleteReply, error)

func (*ProjectService) GetProject 

func (s *ProjectService) GetProject(ctx context.Context, req *projectv1.GetRequest) (*projectv1.GetReply, error)

func (*ProjectService) ListProjects 

func (s *ProjectService) ListProjects(ctx context.Context, req *projectv1.ListsRequest) (*projectv1.ListsReply, error)

func (*ProjectService) SaveProject 

func (s *ProjectService) SaveProject(ctx context.Context, req *projectv1.SaveRequest) (*projectv1.SaveReply, error)

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.