biz

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: 37 Imported by: 0

README

Biz

Documentation

Overview

Package biz is a generated GoMock package.

Index

Constants

View Source 
const (
	TenantLabel               = "coderepo.resource.nautes.io/tenant-management"
	NautesClusterDir          = "nautes/overlays/production/clusters"
	DefaultClusterTemplateURL = "https://github.com/nautes-labs/cluster-templates.git"
	SecretPath                = "default"
	SecretEngine              = "pki"
)
View Source 
const (
	// Argo-operator Index key, Used to obtain roles from the configuration
	ArgoOperator = "Argo"
	// Product default project name
	DefaultProject        = "default.project"
	KustomizationFileName = "kustomization.yaml"
)
View Source 
const (
	// Product naming prefix
	ProductPrefix = "product-"
	// CodeRepo naming prefix
	RepoPrefix = "repo-"
)
View Source 
const (
	// Secret Repo stores git related data engine name
	SecretsGitEngine = "git"
	// Secret Repo stores deploykey key
	SecretsDeployKey = "deploykey"
	// Secret Repo stores access token key
	SecretsAccessToken = "accesstoken"
	// Key data default store user
	DefaultUser = "default"
	// DeployKey fingerprint data Key
	Fingerprint = "fingerprint"
	// DeployKey fingerprint data ID
	DeployKeyID = "id"
)

Secret store Constants.

View Source 
const (
	// AccessToken fingerprint data ID
	AccessTokenID = "id"
	// Access token key path name
	AccessTokenName = "accesstoken-api"
	// Access token scope permissions
	APIPermission AccessTokenPermission = "api"
	// Access token authorization role
	Developer  AccessLevelValue = 30
	Maintainer AccessLevelValue = 40
	Owner      AccessLevelValue = 50
)
View Source 
const (
	// layout resource directory names.
	CodeReposSubDir = "code-repos"
	RuntimesDir     = "runtimes"
	EnvSubDir       = "envs"
	ProjectsDir     = "projects"
)
View Source 
const (
	ResourceInfoKey RescourceContext = "ResourceInfoKey"
	// mark this request method
	SaveMethod   = "Save"
	DeleteMethod = "Delete"
)

Constants used to store commit information.

View Source 
const (
	PerPage = 40
	Page    = 1
)

This is initial page options.

View Source 
const (
	ProjectNotFoud   = "PROJECT_NOT_FOUND"
	GroupNotFound    = "GROUP_NOT_FOUND"
	NodeNotFound     = "NODE_NOT_FOUND"
	ResourceNotFound = "RESOURCE_NOT_FOUND"
	ResourceNotMatch = "RESOURCE_NOT_MATCH"
	NoAuthorization  = "NO_AUTHORIZATION"
	ResourceNotExist = "RESOURCE_NOT_EXIST"
)
View Source 
const (
	GitUser  = "gittestsuer"
	GitEmail = "gittestsuer@nautes.com"
)

Variables

View Source 
var (
	ErrorProjectNotFound = errors.New(404, ProjectNotFoud, "the project path is not found")
	ErrorGroupNotFound   = errors.New(404, GroupNotFound, "the group path is not found")
	ErrorNodetNotFound   = errors.New(404, NodeNotFound, "the node is not found")
	ErrorResourceNoFound = errors.New(404, ResourceNotFound, "the resource is not found")
	ErrorResourceNoMatch = errors.New(500, ResourceNotMatch, "the resource is not match")
	ErrorNoAuth          = errors.New(403, NoAuthorization, "no access to the code repository")
)
View Source 
var ProviderSet = wire.NewSet(NewProjectPipelineRuntimeUsecase, NewDeploymentRuntimeUsecase, NewProductUsecase, NewResourcesUsecase, NewProjectUsecase, NewEnviromentUsecase, NewClusterUsecase, NewCodeRepoUsecase, NewCodeRepoCodeRepoBindingUsecase)

ProviderSet is biz providers.

Functions

func ConvertCodeRepoToRepoName added in v0.4.1 

func ConvertCodeRepoToRepoName(ctx context.Context, codeRepo CodeRepo, codeRepoName string) (string, error)

func ConvertGroupToProductName added in v0.4.1 

func ConvertGroupToProductName(ctx context.Context, codeRepo CodeRepo, productName string) (string, error)

func ConvertProductToGroupName added in v0.4.1 

func ConvertProductToGroupName(ctx context.Context, codeRepo CodeRepo, productName string) (string, error)

func ConvertRepoNameToCodeRepoName added in v0.4.1 

func ConvertRepoNameToCodeRepoName(ctx context.Context, codeRepo CodeRepo, productName, codeRepoName string) (string, error)

func GetClusterTemplateHttpsURL 

func GetClusterTemplateHttpsURL(configs *nautesconfigs.Config) string

func ResourceDoesNotExistOrUnavailable 

func ResourceDoesNotExistOrUnavailable(resourceName, resourceKind, resourcePath string, errMsgs ...string) error

func SetResourceContext 

func SetResourceContext(ctx context.Context, info *RescourceInformation) context.Context

SetResourceContext is mount resource information to context.

func SpliceCodeRepoResourceName 

func SpliceCodeRepoResourceName(id int) string

Types

type AccessLevelValue 

type AccessLevelValue int

type AccessTokenPermission 

type AccessTokenPermission string

type AccessTokenSecretData 

type AccessTokenSecretData struct {
	// The ID of the access token secret
	ID int
}

type BizOptions 

type BizOptions struct {
	ResouceName       string
	ProductName       string
	InsecureSkipCheck bool
}

type Body added in v0.4.0 

type Body struct {
	Token string
}

type CacheStore 

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

type CloneRepositoryParam 

type CloneRepositoryParam struct {
	// The URL of the repository to clone
	URL string
	// The user to use for the clone operation
	User string
	// The email to use for the clone operation
	Email string
}

type ClusterData 

type ClusterData struct {
	ClusterName string
	ApiServer   string
	ClusterType string
	Usage       string
	HostCluster string
}

type ClusterUsecase 

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

func NewClusterUsecase 

func NewClusterUsecase(logger log.Logger, codeRepo CodeRepo, secretRepo Secretrepo, resourcesUsecase *ResourcesUsecase, configs *nautesconfigs.Config, k8sClient client.Client, clusters clustermanagement.ClusterRegistrationOperator, q queue.Queuer) *ClusterUsecase

func (*ClusterUsecase) CloneRepository 

func (c *ClusterUsecase) CloneRepository(ctx context.Context, url string) (string, error)

func (*ClusterUsecase) ConvertKubeconfig 

func (c *ClusterUsecase) ConvertKubeconfig(config, server string) (string, error)

func (*ClusterUsecase) DeleteCluster 

func (c *ClusterUsecase) DeleteCluster(ctx context.Context, clusterName string) error

func (*ClusterUsecase) GetCluster 

func (c *ClusterUsecase) GetCluster(ctx context.Context, clusterName string) (*resourcev1alpha1.Cluster, error)

func (*ClusterUsecase) GetDefaultCertificate 

func (c *ClusterUsecase) GetDefaultCertificate(ctx context.Context) (string, error)

func (*ClusterUsecase) GetTenantRepository 

func (c *ClusterUsecase) GetTenantRepository(ctx context.Context) (*Project, error)

func (*ClusterUsecase) ListClusters 

func (c *ClusterUsecase) ListClusters(ctx context.Context) ([]*resourcev1alpha1.Cluster, error)

func (*ClusterUsecase) RefreshHostCluster added in v0.4.0 

func (c *ClusterUsecase) RefreshHostCluster(clusterName string, bytes []byte) error

func (*ClusterUsecase) SaveCluster 

func (c *ClusterUsecase) SaveCluster(ctx context.Context, param *clustermanagement.ClusterRegistrationParams, kubeconfigData string) error

func (*ClusterUsecase) SaveKubeconfig 

func (c *ClusterUsecase) SaveKubeconfig(ctx context.Context, id, server, config string) error

type CodeRepo 

type CodeRepo interface {
	GetCurrentUser(ctx context.Context) (user string, email string, err error)
	CreateCodeRepo(ctx context.Context, gid int, options *GitCodeRepoOptions) (*Project, error)
	UpdateCodeRepo(ctx context.Context, pid interface{}, options *GitCodeRepoOptions) (*Project, error)
	DeleteCodeRepo(ctx context.Context, pid interface{}) error
	GetCodeRepo(ctx context.Context, pid interface{}) (*Project, error)
	ListDeployKeys(ctx context.Context, pid interface{}, opt *ListOptions) ([]*ProjectDeployKey, error)
	ListAllDeployKeys(ctx context.Context, opt *ListOptions) ([]*ProjectDeployKey, error)
	GetDeployKey(ctx context.Context, pid interface{}, deployKeyID int) (*ProjectDeployKey, error)
	EnableProjectDeployKey(ctx context.Context, pid interface{}, deployKey int) (*ProjectDeployKey, error)
	UpdateDeployKey(ctx context.Context, pid interface{}, deployKey int, title string, canPush bool) (*ProjectDeployKey, error)
	SaveDeployKey(ctx context.Context, pid interface{}, title string, canPush bool, publicKey []byte) (*ProjectDeployKey, error)
	DeleteDeployKey(ctx context.Context, pid interface{}, deployKey int) error
	CreateGroup(ctx context.Context, gitOptions *GitGroupOptions) (*Group, error)
	DeleteGroup(ctx context.Context, gid interface{}) error
	UpdateGroup(ctx context.Context, gid interface{}, git *GitGroupOptions) (*Group, error)
	GetGroup(ctx context.Context, gid interface{}) (*Group, error)
	ListAllGroups(ctx context.Context) ([]*Group, error)
	ListGroupCodeRepos(ctx context.Context, gid interface{}, opts *ListGroupProjectsOptions) ([]*Project, error)
	ListCodeRepos(ctx context.Context, search string) ([]*Project, error)
	ListAccessTokens(ctx context.Context, pid interface{}, opt *ListOptions) ([]*ProjectAccessToken, error)
	GetProjectAccessToken(ctx context.Context, pid interface{}, id int) (*ProjectAccessToken, error)
	CreateProjectAccessToken(ctx context.Context, pid interface{}, opt *CreateProjectAccessTokenOptions) (*ProjectAccessToken, error)
	DeleteProjectAccessToken(ctx context.Context, pid interface{}, id int) error
}

type CodeRepoBindingData 

type CodeRepoBindingData struct {
	Name string
	Spec resourcev1alpha1.CodeRepoBindingSpec
}

type CodeRepoBindingUsecase 

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

func NewCodeRepoCodeRepoBindingUsecase 

func NewCodeRepoCodeRepoBindingUsecase(logger log.Logger, codeRepo CodeRepo, secretRepo Secretrepo, nodeOperator nodestree.NodesTree, resourcesUsecase *ResourcesUsecase, config *nautesconfigs.Config, client client.Client) *CodeRepoBindingUsecase

func (*CodeRepoBindingUsecase) CheckReference 

func (c *CodeRepoBindingUsecase) CheckReference(options nodestree.CompareOptions, node *nodestree.Node, _ client.Client) (bool, error)

func (*CodeRepoBindingUsecase) CreateNode 

func (c *CodeRepoBindingUsecase) CreateNode(path string, data interface{}) (*nodestree.Node, error)

func (*CodeRepoBindingUsecase) CreateResource 

func (c *CodeRepoBindingUsecase) CreateResource(kind string) interface{}

func (*CodeRepoBindingUsecase) DeleteCodeRepoBinding 

func (c *CodeRepoBindingUsecase) DeleteCodeRepoBinding(ctx context.Context, options *BizOptions) error

func (*CodeRepoBindingUsecase) GetCodeRepoBinding 

func (c *CodeRepoBindingUsecase) GetCodeRepoBinding(ctx context.Context, options *BizOptions) (*resourcev1alpha1.CodeRepoBinding, error)

func (*CodeRepoBindingUsecase) GetDeployKeyFromSecretRepo 

func (c *CodeRepoBindingUsecase) GetDeployKeyFromSecretRepo(ctx context.Context, repoName, user, permissions string) (*DeployKeySecretData, error)

func (*CodeRepoBindingUsecase) ListCodeRepoBindings 

func (c *CodeRepoBindingUsecase) ListCodeRepoBindings(ctx context.Context, options *BizOptions) ([]*nodestree.Node, error)

func (*CodeRepoBindingUsecase) SaveCodeRepoBinding 

func (c *CodeRepoBindingUsecase) SaveCodeRepoBinding(ctx context.Context, options *BizOptions, data *CodeRepoBindingData) error

func (*CodeRepoBindingUsecase) UpdateNode 

func (c *CodeRepoBindingUsecase) UpdateNode(resourceNode *nodestree.Node, data interface{}) (*nodestree.Node, error)

type CodeRepoData 

type CodeRepoData struct {
	Name string
	Spec resourcev1alpha1.CodeRepoSpec
}

type CodeRepoPermission added in v0.3.9 

type CodeRepoPermission struct {
	Projects  []string
	IsProduct bool
}

type CodeRepoTotalPermission added in v0.3.9 

type CodeRepoTotalPermission struct {
	CodeRepoName string
	ReadWrite    *CodeRepoPermission
	ReadOnly     *CodeRepoPermission
}

type CodeRepoUsecase 

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

func NewCodeRepoUsecase 

func NewCodeRepoUsecase(logger log.Logger, codeRepo CodeRepo, secretRepo Secretrepo, nodeOperator nodestree.NodesTree, config *nautesconfigs.Config, resourcesUsecase *ResourcesUsecase, codeRepoBindingUsecase *CodeRepoBindingUsecase, client client.Client) *CodeRepoUsecase

func (*CodeRepoUsecase) CheckReference 

func (c *CodeRepoUsecase) CheckReference(options nodestree.CompareOptions, node *nodestree.Node, k8sClient client.Client) (bool, error)

func (*CodeRepoUsecase) CreateNode 

func (c *CodeRepoUsecase) CreateNode(path string, data interface{}) (*nodestree.Node, error)

func (*CodeRepoUsecase) CreateResource 

func (c *CodeRepoUsecase) CreateResource(kind string) interface{}

func (*CodeRepoUsecase) DeleteCodeRepo 

func (c *CodeRepoUsecase) DeleteCodeRepo(ctx context.Context, options *BizOptions) error

func (*CodeRepoUsecase) GetAllAccessTokens 

func (c *CodeRepoUsecase) GetAllAccessTokens(ctx context.Context, pid int) ([]*ProjectAccessToken, error)

func (*CodeRepoUsecase) GetCodeRepo 

func (c *CodeRepoUsecase) GetCodeRepo(ctx context.Context, codeRepoName, productName string) (*ProjectCodeRepo, error)

func (*CodeRepoUsecase) ListAccessTokens 

func (c *CodeRepoUsecase) ListAccessTokens(ctx context.Context, pid int, opts *ListOptions) ([]interface{}, error)

func (*CodeRepoUsecase) ListCodeRepos 

func (c *CodeRepoUsecase) ListCodeRepos(ctx context.Context, productName string) ([]*ProjectCodeRepo, error)

func (*CodeRepoUsecase) SaveCodeRepo 

func (c *CodeRepoUsecase) SaveCodeRepo(ctx context.Context, options *BizOptions, data *CodeRepoData, gitOptions *GitCodeRepoOptions) error

func (*CodeRepoUsecase) UpdateNode 

func (c *CodeRepoUsecase) UpdateNode(node *nodestree.Node, data interface{}) (*nodestree.Node, error)

type CreateProjectAccessTokenOptions 

type CreateProjectAccessTokenOptions struct {
	// Name represents the name of the project access token.
	Name *string `url:"name,omitempty" json:"name,omitempty"`
	// Scopes represents the scopes to be granted to the project access token.
	Scopes *[]string `url:"scopes,omitempty" json:"scopes,omitempty"`
	// AccessLevel represents the access level to be granted to the project access token.
	AccessLevel *AccessLevelValue `url:"access_level,omitempty" json:"access_level,omitempty"`
	// ExpiresAt represents the date and time when the project access token will expire.
	ExpiresAt *ISOTime `url:"expires_at,omitempty" json:"expires_at,omitempty"`
}

type DeployKeyProject 

type DeployKeyProject struct {
	// The ID of the project
	ID int `json:"id"`
	// The description of the project
	Description string `json:"description"`
	// The name of the project
	Name string `json:"name"`
	// The name of the project with namespace
	NameWithNamespace string `json:"name_with_namespace"`
	// The path of the project
	Path string `json:"path"`
	// The path of the project with namespace
	PathWithNamespace string `json:"path_with_namespace"`
	// The date and time when the project was created
	CreatedAt *time.Time `json:"created_at"`
}

type DeployKeySecretData 

type DeployKeySecretData struct {
	// The ID of the deploy key secret
	ID int
	// The fingerprint associated with the deploy key secret
	Fingerprint string
}

type DeployKeyType 

type DeployKeyType string
const (
	// Git read-only and read-write permissions
	ReadOnly  DeployKeyType = "readonly"
	ReadWrite DeployKeyType = "readwrite"
)

type DeploymentRuntimeData 

type DeploymentRuntimeData struct {
	Name string
	Spec resourcev1alpha1.DeploymentRuntimeSpec
}

type DeploymentRuntimeUsecase 

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

func NewDeploymentRuntimeUsecase 

func NewDeploymentRuntimeUsecase(logger log.Logger, codeRepo CodeRepo, nodeOperator nodestree.NodesTree, resourcesUsecase *ResourcesUsecase, k8sClient client.Client, config *nautesconfigs.Config) *DeploymentRuntimeUsecase

func (*DeploymentRuntimeUsecase) CheckReference 

func (d *DeploymentRuntimeUsecase) CheckReference(options nodestree.CompareOptions, node *nodestree.Node, _ client.Client) (bool, error)

func (*DeploymentRuntimeUsecase) CreateNode 

func (d *DeploymentRuntimeUsecase) CreateNode(path string, data interface{}) (*nodestree.Node, error)

func (*DeploymentRuntimeUsecase) CreateResource 

func (d *DeploymentRuntimeUsecase) CreateResource(kind string) interface{}

func (*DeploymentRuntimeUsecase) DeleteDeploymentRuntime 

func (d *DeploymentRuntimeUsecase) DeleteDeploymentRuntime(ctx context.Context, options *BizOptions) error

func (*DeploymentRuntimeUsecase) GetDeploymentRuntime 

func (d *DeploymentRuntimeUsecase) GetDeploymentRuntime(ctx context.Context, deploymentRuntimeName, productName string) (*resourcev1alpha1.DeploymentRuntime, error)

func (*DeploymentRuntimeUsecase) ListDeploymentRuntimes 

func (d *DeploymentRuntimeUsecase) ListDeploymentRuntimes(ctx context.Context, productName string) ([]*nodestree.Node, error)

func (*DeploymentRuntimeUsecase) SaveDeploymentRuntime 

func (d *DeploymentRuntimeUsecase) SaveDeploymentRuntime(ctx context.Context, options *BizOptions, data *DeploymentRuntimeData) error

func (*DeploymentRuntimeUsecase) UpdateNode 

func (d *DeploymentRuntimeUsecase) UpdateNode(resourceNode *nodestree.Node, data interface{}) (*nodestree.Node, error)

type DexRepo 

type DexRepo interface {
	UpdateRedirectURIs(redirectURI string) error
	RemoveRedirectURIs(redirectURIs string) error
}

type EnviromentData 

type EnviromentData struct {
	Name string
	Spec resourcev1alpha1.EnvironmentSpec
}

type EnvironmentUsecase 

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

func NewEnviromentUsecase 

func NewEnviromentUsecase(logger log.Logger, config *nautesconfigs.Config, codeRepo CodeRepo, nodeOperator nodestree.NodesTree, resourcesUsecase *ResourcesUsecase) *EnvironmentUsecase

func (*EnvironmentUsecase) CheckReference 

func (e *EnvironmentUsecase) CheckReference(options nodestree.CompareOptions, node *nodestree.Node, k8sClient client.Client) (bool, error)

func (*EnvironmentUsecase) ConvertProductToGroupName 

func (e *EnvironmentUsecase) ConvertProductToGroupName(ctx context.Context, env *resourcev1alpha1.Environment) error

func (*EnvironmentUsecase) CreateNode 

func (e *EnvironmentUsecase) CreateNode(path string, data interface{}) (*nodestree.Node, error)

func (*EnvironmentUsecase) CreateResource 

func (e *EnvironmentUsecase) CreateResource(kind string) interface{}

func (*EnvironmentUsecase) DeleteEnvironment 

func (e *EnvironmentUsecase) DeleteEnvironment(ctx context.Context, options *BizOptions) error

func (*EnvironmentUsecase) GetEnvironment 

func (e *EnvironmentUsecase) GetEnvironment(ctx context.Context, enviromentName, productName string) (*resourcev1alpha1.Environment, error)

func (*EnvironmentUsecase) ListEnvironments 

func (e *EnvironmentUsecase) ListEnvironments(ctx context.Context, productName string) ([]*nodestree.Node, error)

func (*EnvironmentUsecase) SaveEnvironment 

func (e *EnvironmentUsecase) SaveEnvironment(ctx context.Context, options *BizOptions, data *EnviromentData) error

func (*EnvironmentUsecase) UpdateNode 

func (e *EnvironmentUsecase) UpdateNode(resourceNode *nodestree.Node, data interface{}) (*nodestree.Node, error)

type GitCodeRepoOptions 

type GitCodeRepoOptions struct {
	Gitlab *GitlabCodeRepoOptions
	Github interface{}
}

type GitGroupOptions 

type GitGroupOptions struct {
	Github *GroupOptions
	Gitlab *GroupOptions
}

type GitRepo 

type GitRepo interface {
	Commit(ctx context.Context, path string) error
	SaveConfig(ctx context.Context, path string) error
	Clone(ctx context.Context, param *CloneRepositoryParam) (string, error)
	Merge(ctx context.Context, path string) (string, error)
	Push(ctx context.Context, path string, command ...string) error
	Diff(ctx context.Context, path string, command ...string) (string, error)
	Fetch(ctx context.Context, path string, command ...string) (string, error)
}

type GitlabCodeRepoOptions 

type GitlabCodeRepoOptions struct {
	// The name of the repository
	Name string `json:"name,omitempty"`
	// The path of the repository
	Path string `json:"path,omitempty"`
	// The visibility level of the repository
	Visibility string `json:"visibility,omitempty"`
	// The description of the repository
	Description string `json:"description,omitempty"`
	// The ID of the namespace to which the repository belongs
	NamespaceID int32 `json:"namespace_id,omitempty"`
}

type Group 

type Group struct {
	ID          int32
	Name        string
	Visibility  string
	Description string
	Path        string
	WebUrl      string
	ParentId    int32
}

func CreateGroup 

func CreateGroup(ctx context.Context, codeRepo CodeRepo, gitOptions *GitGroupOptions) (group *Group, err error)

func GetGroup 

func GetGroup(ctx context.Context, codeRepo CodeRepo, gid interface{}) (group *Group, err error)

func UpdateGroup 

func UpdateGroup(ctx context.Context, codeRepo CodeRepo, _ *nautesconfigs.Config, gid int, git *GitGroupOptions) (group *Group, err error)

type GroupAndProjectItem 

type GroupAndProjectItem struct {
	Group   *Group
	Project *Project
}

type GroupOptions 

type GroupOptions struct {
	// The name of the group
	Name string `json:"name,omitempty"`
	// The path of the group
	Path string `json:"path,omitempty"`
	// The visibility level of the group
	Visibility string `json:"visibility,omitempty"`
	// The description of the group
	Description string `json:"description,omitempty"`
	// The ID of the parent group
	ParentId int32 `json:"parent_id,omitempty"`
}

type ISOTime 

type ISOTime time.Time

Project Access token type definition.

type Kubernetes 

type Kubernetes interface {
	ListCodeRepo(ctx context.Context) (*resourcev1alpha1.CodeRepoList, error)
	ListCodeRepoBindings(ctx context.Context) (*resourcev1alpha1.CodeRepoBindingList, error)
}

type ListFunc added in v0.4.1 

type ListFunc func(ctx context.Context, pid int, opts *ListOptions) ([]interface{}, error)

func ListDeployKeys 

func ListDeployKeys(codeRepo CodeRepo) ListFunc

type ListGroupProjectsOptions added in v0.3.9 

type ListGroupProjectsOptions struct {
	ListOptions
	Search string `url:"search,omitempty" json:"search,omitempty"`
	Sort   string `url:"sort,omitempty" json:"sort,omitempty"`
}

type ListMatchOptions 

type ListMatchOptions func(*resourcev1alpha1.CodeRepo) bool

type ListOptions 

type ListOptions struct {
	// The page number
	Page int `url:"page,omitempty" json:"page,omitempty"`
	// The number of items per page
	PerPage int `url:"per_page,omitempty" json:"per_page,omitempty"`
}

type MockCodeRepo 

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

MockCodeRepo is a mock of CodeRepo interface.

func NewMockCodeRepo 

func NewMockCodeRepo(ctrl *gomock.Controller) *MockCodeRepo

NewMockCodeRepo creates a new mock instance.

func (*MockCodeRepo) CreateCodeRepo 

func (m *MockCodeRepo) CreateCodeRepo(ctx context.Context, gid int, options *GitCodeRepoOptions) (*Project, error)

CreateCodeRepo mocks base method.

func (*MockCodeRepo) CreateGroup 

func (m *MockCodeRepo) CreateGroup(ctx context.Context, gitOptions *GitGroupOptions) (*Group, error)

CreateGroup mocks base method.

func (*MockCodeRepo) CreateProjectAccessToken 

func (m *MockCodeRepo) CreateProjectAccessToken(ctx context.Context, pid interface{}, opt *CreateProjectAccessTokenOptions) (*ProjectAccessToken, error)

CreateProjectAccessToken mocks base method.

func (*MockCodeRepo) DeleteCodeRepo 

func (m *MockCodeRepo) DeleteCodeRepo(ctx context.Context, pid interface{}) error

DeleteCodeRepo mocks base method.

func (*MockCodeRepo) DeleteDeployKey 

func (m *MockCodeRepo) DeleteDeployKey(ctx context.Context, pid interface{}, deployKey int) error

DeleteDeployKey mocks base method.

func (*MockCodeRepo) DeleteGroup 

func (m *MockCodeRepo) DeleteGroup(ctx context.Context, gid interface{}) error

DeleteGroup mocks base method.

func (*MockCodeRepo) DeleteProjectAccessToken 

func (m *MockCodeRepo) DeleteProjectAccessToken(ctx context.Context, pid interface{}, id int) error

DeleteProjectAccessToken mocks base method.

func (*MockCodeRepo) EXPECT 

func (m *MockCodeRepo) EXPECT() *MockCodeRepoMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCodeRepo) EnableProjectDeployKey 

func (m *MockCodeRepo) EnableProjectDeployKey(ctx context.Context, pid interface{}, deployKey int) (*ProjectDeployKey, error)

EnableProjectDeployKey mocks base method.

func (*MockCodeRepo) GetCodeRepo 

func (m *MockCodeRepo) GetCodeRepo(ctx context.Context, pid interface{}) (*Project, error)

GetCodeRepo mocks base method.

func (*MockCodeRepo) GetCurrentUser 

func (m *MockCodeRepo) GetCurrentUser(ctx context.Context) (string, string, error)

GetCurrentUser mocks base method.

func (*MockCodeRepo) GetDeployKey 

func (m *MockCodeRepo) GetDeployKey(ctx context.Context, pid interface{}, deployKeyID int) (*ProjectDeployKey, error)

GetDeployKey mocks base method.

func (*MockCodeRepo) GetGroup 

func (m *MockCodeRepo) GetGroup(ctx context.Context, gid interface{}) (*Group, error)

GetGroup mocks base method.

func (*MockCodeRepo) GetProjectAccessToken 

func (m *MockCodeRepo) GetProjectAccessToken(ctx context.Context, pid interface{}, id int) (*ProjectAccessToken, error)

GetProjectAccessToken mocks base method.

func (*MockCodeRepo) ListAccessTokens 

func (m *MockCodeRepo) ListAccessTokens(ctx context.Context, pid interface{}, opt *ListOptions) ([]*ProjectAccessToken, error)

ListAccessTokens mocks base method.

func (*MockCodeRepo) ListAllDeployKeys 

func (m *MockCodeRepo) ListAllDeployKeys(ctx context.Context, opt *ListOptions) ([]*ProjectDeployKey, error)

ListAllDeployKeys mocks base method.

func (*MockCodeRepo) ListAllGroups 

func (m *MockCodeRepo) ListAllGroups(ctx context.Context) ([]*Group, error)

ListAllGroups mocks base method.

func (*MockCodeRepo) ListCodeRepos 

func (m *MockCodeRepo) ListCodeRepos(ctx context.Context, search string) ([]*Project, error)

ListCodeRepos mocks base method.

func (*MockCodeRepo) ListDeployKeys 

func (m *MockCodeRepo) ListDeployKeys(ctx context.Context, pid interface{}, opt *ListOptions) ([]*ProjectDeployKey, error)

ListDeployKeys mocks base method.

func (*MockCodeRepo) ListGroupCodeRepos 

func (m *MockCodeRepo) ListGroupCodeRepos(ctx context.Context, gid interface{}, opts *ListGroupProjectsOptions) ([]*Project, error)

ListGroupCodeRepos mocks base method.

func (*MockCodeRepo) SaveDeployKey 

func (m *MockCodeRepo) SaveDeployKey(ctx context.Context, pid interface{}, title string, canPush bool, publicKey []byte) (*ProjectDeployKey, error)

SaveDeployKey mocks base method.

func (*MockCodeRepo) UpdateCodeRepo 

func (m *MockCodeRepo) UpdateCodeRepo(ctx context.Context, pid interface{}, options *GitCodeRepoOptions) (*Project, error)

UpdateCodeRepo mocks base method.

func (*MockCodeRepo) UpdateDeployKey 

func (m *MockCodeRepo) UpdateDeployKey(ctx context.Context, pid interface{}, deployKey int, title string, canPush bool) (*ProjectDeployKey, error)

UpdateDeployKey mocks base method.

func (*MockCodeRepo) UpdateGroup 

func (m *MockCodeRepo) UpdateGroup(ctx context.Context, gid interface{}, git *GitGroupOptions) (*Group, error)

UpdateGroup mocks base method.

type MockCodeRepoMockRecorder 

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

MockCodeRepoMockRecorder is the mock recorder for MockCodeRepo.

func (*MockCodeRepoMockRecorder) CreateCodeRepo 

func (mr *MockCodeRepoMockRecorder) CreateCodeRepo(ctx, gid, options interface{}) *gomock.Call

CreateCodeRepo indicates an expected call of CreateCodeRepo.

func (*MockCodeRepoMockRecorder) CreateGroup 

func (mr *MockCodeRepoMockRecorder) CreateGroup(ctx, gitOptions interface{}) *gomock.Call

CreateGroup indicates an expected call of CreateGroup.

func (*MockCodeRepoMockRecorder) CreateProjectAccessToken 

func (mr *MockCodeRepoMockRecorder) CreateProjectAccessToken(ctx, pid, opt interface{}) *gomock.Call

CreateProjectAccessToken indicates an expected call of CreateProjectAccessToken.

func (*MockCodeRepoMockRecorder) DeleteCodeRepo 

func (mr *MockCodeRepoMockRecorder) DeleteCodeRepo(ctx, pid interface{}) *gomock.Call

DeleteCodeRepo indicates an expected call of DeleteCodeRepo.

func (*MockCodeRepoMockRecorder) DeleteDeployKey 

func (mr *MockCodeRepoMockRecorder) DeleteDeployKey(ctx, pid, deployKey interface{}) *gomock.Call

DeleteDeployKey indicates an expected call of DeleteDeployKey.

func (*MockCodeRepoMockRecorder) DeleteGroup 

func (mr *MockCodeRepoMockRecorder) DeleteGroup(ctx, gid interface{}) *gomock.Call

DeleteGroup indicates an expected call of DeleteGroup.

func (*MockCodeRepoMockRecorder) DeleteProjectAccessToken 

func (mr *MockCodeRepoMockRecorder) DeleteProjectAccessToken(ctx, pid, id interface{}) *gomock.Call

DeleteProjectAccessToken indicates an expected call of DeleteProjectAccessToken.

func (*MockCodeRepoMockRecorder) EnableProjectDeployKey 

func (mr *MockCodeRepoMockRecorder) EnableProjectDeployKey(ctx, pid, deployKey interface{}) *gomock.Call

EnableProjectDeployKey indicates an expected call of EnableProjectDeployKey.

func (*MockCodeRepoMockRecorder) GetCodeRepo 

func (mr *MockCodeRepoMockRecorder) GetCodeRepo(ctx, pid interface{}) *gomock.Call

GetCodeRepo indicates an expected call of GetCodeRepo.

func (*MockCodeRepoMockRecorder) GetCurrentUser 

func (mr *MockCodeRepoMockRecorder) GetCurrentUser(ctx interface{}) *gomock.Call

GetCurrentUser indicates an expected call of GetCurrentUser.

func (*MockCodeRepoMockRecorder) GetDeployKey 

func (mr *MockCodeRepoMockRecorder) GetDeployKey(ctx, pid, deployKeyID interface{}) *gomock.Call

GetDeployKey indicates an expected call of GetDeployKey.

func (*MockCodeRepoMockRecorder) GetGroup 

func (mr *MockCodeRepoMockRecorder) GetGroup(ctx, gid interface{}) *gomock.Call

GetGroup indicates an expected call of GetGroup.

func (*MockCodeRepoMockRecorder) GetProjectAccessToken 

func (mr *MockCodeRepoMockRecorder) GetProjectAccessToken(ctx, pid, id interface{}) *gomock.Call

GetProjectAccessToken indicates an expected call of GetProjectAccessToken.

func (*MockCodeRepoMockRecorder) ListAccessTokens 

func (mr *MockCodeRepoMockRecorder) ListAccessTokens(ctx, pid, opt interface{}) *gomock.Call

ListAccessTokens indicates an expected call of ListAccessTokens.

func (*MockCodeRepoMockRecorder) ListAllDeployKeys 

func (mr *MockCodeRepoMockRecorder) ListAllDeployKeys(ctx, opt interface{}) *gomock.Call

ListAllDeployKeys indicates an expected call of ListAllDeployKeys.

func (*MockCodeRepoMockRecorder) ListAllGroups 

func (mr *MockCodeRepoMockRecorder) ListAllGroups(ctx interface{}) *gomock.Call

ListAllGroups indicates an expected call of ListAllGroups.

func (*MockCodeRepoMockRecorder) ListCodeRepos 

func (mr *MockCodeRepoMockRecorder) ListCodeRepos(ctx, search interface{}) *gomock.Call

ListCodeRepos indicates an expected call of ListCodeRepos.

func (*MockCodeRepoMockRecorder) ListDeployKeys 

func (mr *MockCodeRepoMockRecorder) ListDeployKeys(ctx, pid, opt interface{}) *gomock.Call

ListDeployKeys indicates an expected call of ListDeployKeys.

func (*MockCodeRepoMockRecorder) ListGroupCodeRepos 

func (mr *MockCodeRepoMockRecorder) ListGroupCodeRepos(ctx, gid, opts interface{}) *gomock.Call

ListGroupCodeRepos indicates an expected call of ListGroupCodeRepos.

func (*MockCodeRepoMockRecorder) SaveDeployKey 

func (mr *MockCodeRepoMockRecorder) SaveDeployKey(ctx, pid, title, canPush, publicKey interface{}) *gomock.Call

SaveDeployKey indicates an expected call of SaveDeployKey.

func (*MockCodeRepoMockRecorder) UpdateCodeRepo 

func (mr *MockCodeRepoMockRecorder) UpdateCodeRepo(ctx, pid, options interface{}) *gomock.Call

UpdateCodeRepo indicates an expected call of UpdateCodeRepo.

func (*MockCodeRepoMockRecorder) UpdateDeployKey 

func (mr *MockCodeRepoMockRecorder) UpdateDeployKey(ctx, pid, deployKey, title, canPush interface{}) *gomock.Call

UpdateDeployKey indicates an expected call of UpdateDeployKey.

func (*MockCodeRepoMockRecorder) UpdateGroup 

func (mr *MockCodeRepoMockRecorder) UpdateGroup(ctx, gid, git interface{}) *gomock.Call

UpdateGroup indicates an expected call of UpdateGroup.

type MockDexRepo 

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

MockDexRepo is a mock of DexRepo interface.

func NewMockDexRepo 

func NewMockDexRepo(ctrl *gomock.Controller) *MockDexRepo

NewMockDexRepo creates a new mock instance.

func (*MockDexRepo) EXPECT 

func (m *MockDexRepo) EXPECT() *MockDexRepoMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDexRepo) RemoveRedirectURIs 

func (m *MockDexRepo) RemoveRedirectURIs(redirectURIs string) error

RemoveRedirectURIs mocks base method.

func (*MockDexRepo) UpdateRedirectURIs 

func (m *MockDexRepo) UpdateRedirectURIs(redirectURI string) error

UpdateRedirectURIs mocks base method.

type MockDexRepoMockRecorder 

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

MockDexRepoMockRecorder is the mock recorder for MockDexRepo.

func (*MockDexRepoMockRecorder) RemoveRedirectURIs 

func (mr *MockDexRepoMockRecorder) RemoveRedirectURIs(redirectURIs interface{}) *gomock.Call

RemoveRedirectURIs indicates an expected call of RemoveRedirectURIs.

func (*MockDexRepoMockRecorder) UpdateRedirectURIs 

func (mr *MockDexRepoMockRecorder) UpdateRedirectURIs(redirectURI interface{}) *gomock.Call

UpdateRedirectURIs indicates an expected call of UpdateRedirectURIs.

type MockGitRepo 

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

MockGitRepo is a mock of GitRepo interface.

func NewMockGitRepo 

func NewMockGitRepo(ctrl *gomock.Controller) *MockGitRepo

NewMockGitRepo creates a new mock instance.

func (*MockGitRepo) Clone 

func (m *MockGitRepo) Clone(ctx context.Context, param *CloneRepositoryParam) (string, error)

Clone mocks base method.

func (*MockGitRepo) Commit 

func (m *MockGitRepo) Commit(ctx context.Context, path string) error

Commit mocks base method.

func (*MockGitRepo) Diff 

func (m *MockGitRepo) Diff(ctx context.Context, path string, command ...string) (string, error)

Diff mocks base method.

func (*MockGitRepo) EXPECT 

func (m *MockGitRepo) EXPECT() *MockGitRepoMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockGitRepo) Fetch 

func (m *MockGitRepo) Fetch(ctx context.Context, path string, command ...string) (string, error)

Fetch mocks base method.

func (*MockGitRepo) Merge 

func (m *MockGitRepo) Merge(ctx context.Context, path string) (string, error)

Merge mocks base method.

func (*MockGitRepo) Push 

func (m *MockGitRepo) Push(ctx context.Context, path string, command ...string) error

Push mocks base method.

func (*MockGitRepo) SaveConfig 

func (m *MockGitRepo) SaveConfig(ctx context.Context, path string) error

SaveConfig mocks base method.

type MockGitRepoMockRecorder 

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

MockGitRepoMockRecorder is the mock recorder for MockGitRepo.

func (*MockGitRepoMockRecorder) Clone 

func (mr *MockGitRepoMockRecorder) Clone(ctx, param interface{}) *gomock.Call

Clone indicates an expected call of Clone.

func (*MockGitRepoMockRecorder) Commit 

func (mr *MockGitRepoMockRecorder) Commit(ctx, path interface{}) *gomock.Call

Commit indicates an expected call of Commit.

func (*MockGitRepoMockRecorder) Diff 

func (mr *MockGitRepoMockRecorder) Diff(ctx, path interface{}, command ...interface{}) *gomock.Call

Diff indicates an expected call of Diff.

func (*MockGitRepoMockRecorder) Fetch 

func (mr *MockGitRepoMockRecorder) Fetch(ctx, path interface{}, command ...interface{}) *gomock.Call

Fetch indicates an expected call of Fetch.

func (*MockGitRepoMockRecorder) Merge 

func (mr *MockGitRepoMockRecorder) Merge(ctx, path interface{}) *gomock.Call

Merge indicates an expected call of Merge.

func (*MockGitRepoMockRecorder) Push 

func (mr *MockGitRepoMockRecorder) Push(ctx, path interface{}, command ...interface{}) *gomock.Call

Push indicates an expected call of Push.

func (*MockGitRepoMockRecorder) SaveConfig 

func (mr *MockGitRepoMockRecorder) SaveConfig(ctx, path interface{}) *gomock.Call

SaveConfig indicates an expected call of SaveConfig.

type MockKubernetes 

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

MockKubernetes is a mock of Kubernetes interface.

func NewMockKubernetes 

func NewMockKubernetes(ctrl *gomock.Controller) *MockKubernetes

NewMockKubernetes creates a new mock instance.

func (*MockKubernetes) EXPECT 

func (m *MockKubernetes) EXPECT() *MockKubernetesMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockKubernetes) ListCodeRepo 

func (m *MockKubernetes) ListCodeRepo(ctx context.Context) (*v1alpha1.CodeRepoList, error)

ListCodeRepo mocks base method.

func (*MockKubernetes) ListCodeRepoBindings 

func (m *MockKubernetes) ListCodeRepoBindings(ctx context.Context) (*v1alpha1.CodeRepoBindingList, error)

ListCodeRepoBindings mocks base method.

type MockKubernetesMockRecorder 

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

MockKubernetesMockRecorder is the mock recorder for MockKubernetes.

func (*MockKubernetesMockRecorder) ListCodeRepo 

func (mr *MockKubernetesMockRecorder) ListCodeRepo(ctx interface{}) *gomock.Call

ListCodeRepo indicates an expected call of ListCodeRepo.

func (*MockKubernetesMockRecorder) ListCodeRepoBindings 

func (mr *MockKubernetesMockRecorder) ListCodeRepoBindings(ctx interface{}) *gomock.Call

ListCodeRepoBindings indicates an expected call of ListCodeRepoBindings.

type MockSecretrepo 

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

MockSecretrepo is a mock of Secretrepo interface.

func NewMockSecretrepo 

func NewMockSecretrepo(ctrl *gomock.Controller) *MockSecretrepo

NewMockSecretrepo creates a new mock instance.

func (*MockSecretrepo) AuthorizationSecret 

func (m *MockSecretrepo) AuthorizationSecret(ctx context.Context, id int, destUser, gitType, mountPath string) error

AuthorizationSecret mocks base method.

func (*MockSecretrepo) DeleteSecret 

func (m *MockSecretrepo) DeleteSecret(ctx context.Context, id int, user, permission string) error

DeleteSecret mocks base method.

func (*MockSecretrepo) EXPECT 

func (m *MockSecretrepo) EXPECT() *MockSecretrepoMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSecretrepo) GetDeployKey 

func (m *MockSecretrepo) GetDeployKey(ctx context.Context, secretOptions *SecretOptions) (*DeployKeySecretData, error)

GetDeployKey mocks base method.

func (*MockSecretrepo) GetProjectAccessToken 

func (m *MockSecretrepo) GetProjectAccessToken(ctx context.Context, secretOptions *SecretOptions) (*AccessTokenSecretData, error)

GetProjectAccessToken mocks base method.

func (*MockSecretrepo) GetSecret 

func (m *MockSecretrepo) GetSecret(ctx context.Context, secretOptions *SecretOptions) (string, error)

GetSecret mocks base method.

func (*MockSecretrepo) SaveClusterConfig 

func (m *MockSecretrepo) SaveClusterConfig(ctx context.Context, id, config string) error

SaveClusterConfig mocks base method.

func (*MockSecretrepo) SaveDeployKey 

func (m *MockSecretrepo) SaveDeployKey(ctx context.Context, data *SecretData, extendKVs map[string]string) error

SaveDeployKey mocks base method.

func (*MockSecretrepo) SaveProjectAccessToken 

func (m *MockSecretrepo) SaveProjectAccessToken(ctx context.Context, id, token, user, permission string, extendKVs map[string]string) error

SaveProjectAccessToken mocks base method.

type MockSecretrepoMockRecorder 

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

MockSecretrepoMockRecorder is the mock recorder for MockSecretrepo.

func (*MockSecretrepoMockRecorder) AuthorizationSecret 

func (mr *MockSecretrepoMockRecorder) AuthorizationSecret(ctx, id, destUser, gitType, mountPath interface{}) *gomock.Call

AuthorizationSecret indicates an expected call of AuthorizationSecret.

func (*MockSecretrepoMockRecorder) DeleteSecret 

func (mr *MockSecretrepoMockRecorder) DeleteSecret(ctx, id, user, permission interface{}) *gomock.Call

DeleteSecret indicates an expected call of DeleteSecret.

func (*MockSecretrepoMockRecorder) GetDeployKey 

func (mr *MockSecretrepoMockRecorder) GetDeployKey(ctx, secretOptions interface{}) *gomock.Call

GetDeployKey indicates an expected call of GetDeployKey.

func (*MockSecretrepoMockRecorder) GetProjectAccessToken 

func (mr *MockSecretrepoMockRecorder) GetProjectAccessToken(ctx, secretOptions interface{}) *gomock.Call

GetProjectAccessToken indicates an expected call of GetProjectAccessToken.

func (*MockSecretrepoMockRecorder) GetSecret 

func (mr *MockSecretrepoMockRecorder) GetSecret(ctx, secretOptions interface{}) *gomock.Call

GetSecret indicates an expected call of GetSecret.

func (*MockSecretrepoMockRecorder) SaveClusterConfig 

func (mr *MockSecretrepoMockRecorder) SaveClusterConfig(ctx, id, config interface{}) *gomock.Call

SaveClusterConfig indicates an expected call of SaveClusterConfig.

func (*MockSecretrepoMockRecorder) SaveDeployKey 

func (mr *MockSecretrepoMockRecorder) SaveDeployKey(ctx, data, extendKVs interface{}) *gomock.Call

SaveDeployKey indicates an expected call of SaveDeployKey.

func (*MockSecretrepoMockRecorder) SaveProjectAccessToken 

func (mr *MockSecretrepoMockRecorder) SaveProjectAccessToken(ctx, id, token, user, permission, extendKVs interface{}) *gomock.Call

SaveProjectAccessToken indicates an expected call of SaveProjectAccessToken.

type ProductAuthorization 

type ProductAuthorization struct {
	ProductName   string
	ProjectScopes map[string]bool
	// contains filtered or unexported fields
}

type ProductUsecase 

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

ProductUsecase is a Product usecase.

func NewProductUsecase 

func NewProductUsecase(logger log.Logger, codeRepo CodeRepo, secretRepo Secretrepo, gitRepo GitRepo, configs *nautesconfigs.Config, resourcesUsecase *ResourcesUsecase, codeRepoUsecase *CodeRepoUsecase) *ProductUsecase

func (*ProductUsecase) DeleteProduct 

func (p *ProductUsecase) DeleteProduct(ctx context.Context, productID string) error

func (*ProductUsecase) GetGroupAndDefaultProject 

func (p *ProductUsecase) GetGroupAndDefaultProject(ctx context.Context, productName string) (*GroupAndProjectItem, error)

func (*ProductUsecase) GetProduct 

func (p *ProductUsecase) GetProduct(ctx context.Context, productName string) (*GroupAndProjectItem, error)

func (*ProductUsecase) ListProducts 

func (p *ProductUsecase) ListProducts(ctx context.Context) ([]*GroupAndProjectItem, error)

func (*ProductUsecase) SaveProduct 

func (p *ProductUsecase) SaveProduct(ctx context.Context, productName string, gitOptions *GitGroupOptions) (group *Group, project *Project, err error)

type Project 

type Project struct {
	ID                int32
	Name              string
	Visibility        string
	Description       string
	Path              string
	WebUrl            string
	SshUrlToRepo      string
	HttpUrlToRepo     string
	PathWithNamespace string
	Namespace         *ProjectNamespace
}

func GetProject 

func GetProject(ctx context.Context, codeRepo CodeRepo, pid interface{}) (project *Project, err error)

type ProjectAccessToken 

type ProjectAccessToken struct {
	// ID represents the unique identifier of the project access token.
	ID int `json:"id"`
	// UserID represents the unique identifier of the user associated with the project access token.
	UserID int `json:"user_id"`
	// Name represents the name of the project access token.
	Name string `json:"name"`
	// Scopes represents the scopes granted to the project access token.
	Scopes []string `json:"scopes"`
	// CreatedAt represents the date and time when the project access token was created.
	CreatedAt *time.Time `json:"created_at"`
	// LastUsedAt represents the date and time when the project access token was last used.
	LastUsedAt *time.Time `json:"last_used_at"`
	// ExpiresAt represents the date and time when the project access token will expire.
	ExpiresAt *ISOTime `json:"expires_at"`
	// Active represents whether the project access token is active or not.
	Active bool `json:"active"`
	// Revoked represents whether the project access token has been revoked or not.
	Revoked bool `json:"revoked"`
	// Token represents the value of the project access token.
	Token string `json:"token"`
	// AccessLevel represents the access level granted to the project access token.
	AccessLevel AccessLevelValue `json:"access_level"`
}

type ProjectCodeRepo 

type ProjectCodeRepo struct {
	CodeRepo *resourcev1alpha1.CodeRepo
	Project  *Project
}

type ProjectData 

type ProjectData struct {
	ProjectName string
	ProductName string
	Language    string
}

type ProjectDeployKey 

type ProjectDeployKey struct {
	// The ID of the deploy key
	ID int `json:"id"`
	// The title of the deploy key
	Title string `json:"title"`
	// The key value of the deploy key
	Key string `json:"key"`
	// The date and time when the deploy key was created
	CreatedAt *time.Time `json:"created_at"`
	// Whether the deploy key has push access
	CanPush bool `json:"can_push"`
	// The fingerprint of the deploy key
	Fingerprint string `json:"fingerprint"`
	// The projects that have write access to this deploy key
	ProjectsWithWriteAccess []*DeployKeyProject `json:"projects_with_write_access"`
}

func GetAllDeployKeys 

func GetAllDeployKeys(ctx context.Context, codeRepo CodeRepo, pid int) ([]*ProjectDeployKey, error)

type ProjectNamespace 

type ProjectNamespace struct {
	ID        int
	Name      string
	Path      string
	Kind      string
	FullPath  string
	AvatarURL string
	WebURL    string
}

type ProjectPipelineRuntimeData 

type ProjectPipelineRuntimeData struct {
	Name string
	Spec resourcev1alpha1.ProjectPipelineRuntimeSpec
}

type ProjectPipelineRuntimeUsecase 

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

func NewProjectPipelineRuntimeUsecase 

func NewProjectPipelineRuntimeUsecase(logger log.Logger, codeRepo CodeRepo, nodeOperator nodestree.NodesTree, resourcesUsecase *ResourcesUsecase, k8sClient client.Client, config *nautesconfigs.Config) *ProjectPipelineRuntimeUsecase

func (*ProjectPipelineRuntimeUsecase) CheckReference 

func (p *ProjectPipelineRuntimeUsecase) CheckReference(options nodestree.CompareOptions, node *nodestree.Node, _ client.Client) (bool, error)

func (*ProjectPipelineRuntimeUsecase) CreateNode 

func (p *ProjectPipelineRuntimeUsecase) CreateNode(path string, data interface{}) (*nodestree.Node, error)

func (*ProjectPipelineRuntimeUsecase) CreateResource 

func (p *ProjectPipelineRuntimeUsecase) CreateResource(kind string) interface{}

func (*ProjectPipelineRuntimeUsecase) DeleteProjectPipelineRuntime 

func (p *ProjectPipelineRuntimeUsecase) DeleteProjectPipelineRuntime(ctx context.Context, options *BizOptions) error

func (*ProjectPipelineRuntimeUsecase) GetProjectPipelineRuntime 

func (p *ProjectPipelineRuntimeUsecase) GetProjectPipelineRuntime(ctx context.Context, projectPipelineName, productName string) (*nodestree.Node, error)

func (*ProjectPipelineRuntimeUsecase) IsRepositoryExist 

func (p *ProjectPipelineRuntimeUsecase) IsRepositoryExist(ctx context.Context, productName, repoName string) (*Project, error)

func (*ProjectPipelineRuntimeUsecase) ListProjectPipelineRuntimes 

func (p *ProjectPipelineRuntimeUsecase) ListProjectPipelineRuntimes(ctx context.Context, productName string) ([]*nodestree.Node, error)

func (*ProjectPipelineRuntimeUsecase) SaveProjectPipelineRuntime 

func (p *ProjectPipelineRuntimeUsecase) SaveProjectPipelineRuntime(ctx context.Context, options *BizOptions, data *ProjectPipelineRuntimeData) error

func (*ProjectPipelineRuntimeUsecase) UpdateNode 

func (p *ProjectPipelineRuntimeUsecase) UpdateNode(node *nodestree.Node, data interface{}) (*nodestree.Node, error)

type ProjectUsecase 

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

func NewProjectUsecase 

func NewProjectUsecase(logger log.Logger, codeRepo CodeRepo, secretRepo Secretrepo, nodeOperator nodestree.NodesTree, configs *nautesconfigs.Config, resourcesUsecase *ResourcesUsecase) *ProjectUsecase

func (*ProjectUsecase) CheckReference 

func (p *ProjectUsecase) CheckReference(options nodestree.CompareOptions, node *nodestree.Node, _ client.Client) (bool, error)

func (*ProjectUsecase) CreateNode 

func (p *ProjectUsecase) CreateNode(path string, data interface{}) (*nodestree.Node, error)

func (*ProjectUsecase) CreateResource 

func (p *ProjectUsecase) CreateResource(kind string) interface{}

func (*ProjectUsecase) DeleteProject 

func (p *ProjectUsecase) DeleteProject(ctx context.Context, options *BizOptions) error

func (*ProjectUsecase) GetProject 

func (p *ProjectUsecase) GetProject(ctx context.Context, projectName, productName string) (*resourcev1alpha1.Project, error)

func (*ProjectUsecase) ListProjects 

func (p *ProjectUsecase) ListProjects(ctx context.Context, productName string) ([]*resourcev1alpha1.Project, error)

func (*ProjectUsecase) SaveProject 

func (p *ProjectUsecase) SaveProject(ctx context.Context, options *BizOptions, data *ProjectData) error

func (*ProjectUsecase) UpdateNode 

func (p *ProjectUsecase) UpdateNode(resourceNode *nodestree.Node, data interface{}) (*nodestree.Node, error)

type RescourceContext added in v0.4.1 

type RescourceContext string

type RescourceInformation added in v0.4.1 

type RescourceInformation struct {
	ProductName       string
	Method            string
	ParentResouceKind string
	ParentResouceName string
	ResourceKind      string
	ResourceName      string
}

type ResourceInfo 

type ResourceInfo struct {
	// The product name to which the resource belongs
	ProductName string
	// Method of operating resources
	Method string
	// Parent class resource kind
	ParentResouceKind string
	// Parent class resource name
	ParentResourceName string
	// Current resource kind
	ResourceKind string
	// Current resource name
	ResourceName string
}

type ResourcesUsecase 

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

func NewResourcesUsecase 

func NewResourcesUsecase(logger log.Logger, codeRepo CodeRepo, secretRepo Secretrepo, gitRepo GitRepo, nodeOperator nodestree.NodesTree, configs *nautesconfigs.Config) *ResourcesUsecase

func (*ResourcesUsecase) CloneCodeRepo 

func (r *ResourcesUsecase) CloneCodeRepo(ctx context.Context, url string) (path string, err error)

func (*ResourcesUsecase) Delete 

func (r *ResourcesUsecase) Delete(ctx context.Context, resourceOptions *resourceOptions, getResourceName getResouceName) error

func (*ResourcesUsecase) Get 

func (r *ResourcesUsecase) Get(ctx context.Context, resourceKind, productName string, _ nodestree.NodesOperator, getResourceName getResouceName) (*nodestree.Node, error)

func (*ResourcesUsecase) GetCodeRepo 

func (r *ResourcesUsecase) GetCodeRepo(ctx context.Context, productName, codeRepoName string) (*Project, error)

GetCodeRepoName The name of the codeRepo resource must be prefixed with repo-, eg: repo-1

func (*ResourcesUsecase) GetGroupAndProjectByGroupID 

func (r *ResourcesUsecase) GetGroupAndProjectByGroupID(ctx context.Context, gid interface{}) (*Group, *Project, error)

func (*ResourcesUsecase) GetNode 

func (r *ResourcesUsecase) GetNode(nodes *nodestree.Node, kind, resourceName string) *nodestree.Node

GetNode get specifial node according to resource kind and name

func (*ResourcesUsecase) GetNodes 

func (r *ResourcesUsecase) GetNodes() (*nodestree.Node, error)

func (*ResourcesUsecase) InsertNodes 

func (r *ResourcesUsecase) InsertNodes(nodeOperator nodestree.NodesTree, nodes, resource *nodestree.Node) (*nodestree.Node, error)

func (*ResourcesUsecase) List 

func (r *ResourcesUsecase) List(ctx context.Context, gid interface{}, _ nodestree.NodesOperator) (*nodestree.Node, error)

func (*ResourcesUsecase) PushToGit added in v0.4.0 

func (r *ResourcesUsecase) PushToGit(ctx context.Context, path string) error

PushToGit Save project resource config to git platform If automatic merge fails will retry three times

func (*ResourcesUsecase) RemoveNode 

func (r *ResourcesUsecase) RemoveNode(nodes, node *nodestree.Node) (*nodestree.Node, error)

RemoveNode delete the specified node according to the path

func (*ResourcesUsecase) Save 

func (r *ResourcesUsecase) Save(ctx context.Context, resourceOptions *resourceOptions, data interface{}) error

Save create or update config to git platform

func (*ResourcesUsecase) WriteResource 

func (r *ResourcesUsecase) WriteResource(node *nodestree.Node) error

WriteResource Write project resource content to a file

type RretryCountType 

type RretryCountType string
const (
	// When pushing code configuration, there is a key with a context retry.
	RretryCount RretryCountType = "RretryCount"
)

type SecretData 

type SecretData struct {
	// The ID of the secret
	ID int `json:"id"`
	// The data associated with the secret
	Name       string `json:"name"`
	Data       string `json:"data"`
	Permission string `json:"permission"`
	Key        string `json:"tag"`
	User       string `json:"user"`
}

type SecretOptions 

type SecretOptions struct {
	// The path of the secret
	SecretPath string
	// The engine used to store the secret
	SecretEngine string
	// The key used to access the secret
	SecretKey string
}

type Secretrepo 

type Secretrepo interface {
	GetSecret(ctx context.Context, secretOptions *SecretOptions) (string, error)
	GetDeployKey(ctx context.Context, secretOptions *SecretOptions) (*DeployKeySecretData, error)
	SaveDeployKey(ctx context.Context, data *SecretData, extendKVs map[string]string) error
	SaveProjectAccessToken(ctx context.Context, id, token, user, permission string, extendKVs map[string]string) error
	SaveClusterConfig(ctx context.Context, id, config string) error
	DeleteSecret(ctx context.Context, id int, user, permission string) error
	AuthorizationSecret(ctx context.Context, id int, destUser, gitType, mountPath string) error
	GetProjectAccessToken(ctx context.Context, secretOptions *SecretOptions) (*AccessTokenSecretData, 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.