biz

package

Go to main page

Versions in this module

v0

v0.3.6

Jul 28, 2023

Changes in this version

+ const ResourceNotExist

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

+ type ProjectCodeRepo struct

+ CodeRepo *resourcev1alpha1.CodeRepo

+ Project *Project

type ResourcesUsecase

+ func (r *ResourcesUsecase) ConvertGroupToProductName(ctx context.Context, productName string) (string, error)

v0.3.5

Jul 14, 2023

Changes in this version

+ const ArgoOperator

+ const CodeReposSubDir

+ const EnvSubDir

+ const NautesClusterDir

+ const ProductPrefix

+ const ProjectsDir

+ const RuntimesDir

+ const TenantLabel

+ func GetClusterFromTenantRepository(tenantRepositoryLocalPath, clusterName string) (*resourcev1alpha1.Cluster, error)

type ClusterUsecase

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

v0.3.4

Jul 4, 2023

Changes in this version

+ const DefaultProject

+ type CacheStore struct

type CodeRepo

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

type Group

+ ID int32

type MockCodeRepo

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

type MockCodeRepoMockRecorder

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

type Project

+ ID int32

v0.3.3

Jun 21, 2023

Changes in this version

+ func Contains(arr []int, target int) bool

type CodeRepoBindingUsecase

+ func (c *CodeRepoBindingUsecase) AuthorizeForSameProjectRepo(ctx context.Context, nodes nodestree.Node, ...) error

v0.3.1

Jun 9, 2023

Changes in this version

+ const DeleteMethod

+ const ResourceInfoKey

+ const SaveMethod

+ func SetResourceContext(ctx context.Context, ...) context.Context

type ClusterUsecase

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

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

type CodeRepoBindingUsecase

+ func (c *CodeRepoBindingUsecase) ConvertRuntime(ctx context.Context, resource *resourcev1alpha1.CodeRepoBinding) error

type CodeRepoUsecase

+ func (c *CodeRepoUsecase) GetProjectByCodeRepoName(ctx context.Context, codeRepoName, productName string) (*resourcev1alpha1.CodeRepo, *Project, error)

type DeploymentRuntimeUsecase

+ func (c *DeploymentRuntimeUsecase) ConvertProductToGroupName(ctx context.Context, runtime *resourcev1alpha1.DeploymentRuntime) error

+ func (d *DeploymentRuntimeUsecase) ConvertRuntime(ctx context.Context, runtime *resourcev1alpha1.DeploymentRuntime) error

+ func (p *DeploymentRuntimeUsecase) ConvertCodeRepoToRepoName(ctx context.Context, runtime *resourcev1alpha1.DeploymentRuntime) error

type EnvironmentUsecase

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

type ProjectPipelineRuntimeUsecase

+ func (p *ProjectPipelineRuntimeUsecase) ConvertCodeRepoToRepoName(ctx context.Context, runtime *resourcev1alpha1.ProjectPipelineRuntime) error

+ type ResourceInfo struct

+ Method string

+ ParentResouceKind string

+ ParentResourceName string

+ ProductName string

+ ResourceKind string

+ ResourceName string

type ResourcesUsecase

+ func (r *ResourcesUsecase) ConvertCodeRepoToRepoName(ctx context.Context, codeRepoName string) (string, error)

+ func (r *ResourcesUsecase) ConvertGroupToProduct(ctx context.Context, productName string) (string, error)

+ func (r *ResourcesUsecase) ConvertProductToGroupName(ctx context.Context, productName string) (string, error)

+ func (r *ResourcesUsecase) ConvertRepoNameToCodeRepo(ctx context.Context, productName, codeRepoName string) (string, error)

v0.3.0

May 27, 2023

Changes in this version

+ const APIPermission

+ const AccessTokenID

+ const AccessTokenName

+ const DefaultClusterTemplateURL

+ const DefaultUser

+ const DeployKeyID

+ const Developer

+ const Fingerprint

+ const Maintainer

+ const Owner

+ const ReadOnly

+ const ReadWrite

+ const RepoPrefix

+ const SecretsAccessToken

+ const SecretsDeployKey

+ const SecretsGitEngine

+ func ListDeployKeys(ctx context.Context, codeRepo CodeRepo, pid int, opts *ListOptions) listFunc

+ type AccessLevelValue int

+ type AccessTokenPermission string

+ type AccessTokenSecretData struct

+ ID int

type CodeRepo

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

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

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

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

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

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

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

+ type CodeRepoBindingData struct

+ Name string

+ Spec resourcev1alpha1.CodeRepoBindingSpec

+ type CodeRepoBindingUsecase struct

+ func NewCodeRepoCodeRepoBindingUsecase(logger log.Logger, codeRepo CodeRepo, secretRepo Secretrepo, ...) *CodeRepoBindingUsecase

+ func (c *CodeRepoBindingUsecase) AuthorizeForSameProjectRepository(ctx context.Context, nodes nodestree.Node, permissions, currentProject string) error

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

+ func (c *CodeRepoBindingUsecase) ClearOthersDeployKey(ctx context.Context, pid int) error

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

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

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

+ func (c *CodeRepoBindingUsecase) GetAuthorizedRepositories(ctx context.Context, spec resourcev1alpha1.CodeRepoBindingSpec) ([]*Project, error)

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

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

+ func (c *CodeRepoBindingUsecase) ListCodeRepoBindings(ctx context.Context, options *BizOptions) ([]*resourcev1alpha1.CodeRepoBinding, error)

+ func (c *CodeRepoBindingUsecase) RevokeDeployKey(ctx context.Context, concodeRepos []*resourcev1alpha1.CodeRepo, ...) error

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

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

type CodeRepoUsecase

+ func (c *CodeRepoUsecase) FilterAccessTokensByIDList(ctx context.Context, pid int, idList map[int]bool) ([]*ProjectAccessToken, error)

+ func (c *CodeRepoUsecase) FilterProjectDeployKeysByIDList(ctx context.Context, pid int, idList map[int]bool) ([]*ProjectDeployKey, error)

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

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

+ type CodeRepoWithProject struct

+ CodeRepo *resourcev1alpha1.CodeRepo

+ Project *Project

+ type CreateProjectAccessTokenOptions struct

+ AccessLevel *AccessLevelValue

+ ExpiresAt *ISOTime

+ Name *string

+ Scopes *[]string

+ type DeployKeyProject struct

+ CreatedAt *time.Time

+ Description string

+ ID int

+ Name string

+ NameWithNamespace string

+ Path string

+ PathWithNamespace string

+ type DeployKeyType string

+ type ISOTime time.Time

+ type Kubernetes interface

+ ListCodeRepo func(ctx context.Context) (*resourcev1alpha1.CodeRepoList, error)

+ ListCodeRepoBindings func(ctx context.Context) (*resourcev1alpha1.CodeRepoBindingList, error)

+ type ListMatchOptions func(*resourcev1alpha1.CodeRepo) bool

type MockCodeRepo

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

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

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

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

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

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

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

type MockCodeRepoMockRecorder

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

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

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

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

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

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

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

+ type MockKubernetes struct

+ func NewMockKubernetes(ctrl *gomock.Controller) *MockKubernetes

+ func (m *MockKubernetes) EXPECT() *MockKubernetesMockRecorder

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

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

+ type MockKubernetesMockRecorder struct

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

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

type MockSecretrepo

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

+ func (m *MockSecretrepo) SaveProjectAccessToken(ctx context.Context, id, token, user, permission string, ...) error

type MockSecretrepoMockRecorder

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

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

+ type PipelineRuntimeValidateClient struct

+ func (p *PipelineRuntimeValidateClient) GetCodeRepoBindingList(productName, repoName string) (*resourcev1alpha1.CodeRepoBindingList, error)

+ func (p *PipelineRuntimeValidateClient) GetCodeRepoList(repoName string) (*resourcev1alpha1.CodeRepoList, error)

+ type ProductAuthorization struct

+ ProductName string

+ ProjectScopes map[string]bool

type Project

+ Namespace *ProjectNamespace

+ type ProjectAccessToken struct

+ AccessLevel AccessLevelValue

+ Active bool

+ CreatedAt *time.Time

+ ExpiresAt *ISOTime

+ ID int

+ LastUsedAt *time.Time

+ Name string

+ Revoked bool

+ Scopes []string

+ Token string

+ UserID int

type ProjectDeployKey

+ Fingerprint string

+ ProjectsWithWriteAccess []*DeployKeyProject

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

+ type ProjectNamespace struct

+ AvatarURL string

+ FullPath string

+ ID int

+ Kind string

+ Name string

+ Path string

+ WebURL string

type ProjectPipelineRuntimeUsecase

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

type ResourcesUsecase

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

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

type Secretrepo

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

+ SaveProjectAccessToken func(ctx context.Context, id, token, user, permission string, ...) error

v0.2.1

Apr 18, 2023

v0.2.0

Apr 15, 2023

Changes in this version

+ const GROUP_NOT_FOUND

+ const NODE_NOT_FOUND

+ const NO_AUTHORIZATION

+ const PROJECT_NOT_FOUND

+ const RESOURCE_NOT_FOUND

+ const RESOURCE_NOT_MATCH

+ const SecretEngine

+ const SecretPath

+ const SecretsEngine

+ const SecretsKey

+ var ErrorGroupNotFound = errors.New(404, GROUP_NOT_FOUND, "the group path is not found")

+ var ErrorNoAuth = errors.New(403, NO_AUTHORIZATION, "no access to the code repository")

+ var ErrorNodetNotFound = errors.New(404, NODE_NOT_FOUND, "the node is not found")

+ var ErrorProjectNotFound = errors.New(404, PROJECT_NOT_FOUND, "the project path is not found")

+ var ErrorResourceNoFound = errors.New(404, RESOURCE_NOT_FOUND, "the resource is not found")

+ var ErrorResourceNoMatch = errors.New(500, RESOURCE_NOT_MATCH, "the resource is not match")

+ var ProviderSet = wire.NewSet(NewProjectPipelineRuntimeUsecase, NewDeploymentRuntimeUsecase, ...)

+ func GetCluster(filename string) (*resourcev1alpha1.Cluster, error)

+ func GetClusterTemplateHttpsURL(configs *nautesconfigs.Config) string

+ func SpliceCodeRepoResourceName(id int) string

+ type BizOptions struct

+ InsecureSkipCheck bool

+ ProductName string

+ ResouceName string

+ type CloneRepositoryParam struct

+ Email string

+ URL string

+ User string

+ type ClusterData struct

+ ApiServer string

+ ClusterName string

+ ClusterType string

+ HostCluster string

+ Usage string

+ type ClusterUsecase struct

+ func NewClusterUsecase(logger log.Logger, codeRepo CodeRepo, secretRepo Secretrepo, ...) *ClusterUsecase

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

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

+ func (c *ClusterUsecase) DeleteDexConfig(param *cluster.ClusterRegistrationParam) error

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

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

+ func (c *ClusterUsecase) SaveCluster(ctx context.Context, param *cluster.ClusterRegistrationParam, ...) error

+ func (c *ClusterUsecase) SaveDexConfig(param *cluster.ClusterRegistrationParam, teantLocalPath string) error

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

+ func (r *ClusterUsecase) ConvertKubeconfig(config, server string) (string, error)

+ type CodeRepo interface

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

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

+ DeleteCodeRepo func(ctx context.Context, pid interface{}) error

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

+ DeleteGroup func(ctx context.Context, gid interface{}) error

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

+ GetCurrentUser func(ctx context.Context) (user string, email string, err error)

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

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

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

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

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

+ SaveDeployKey func(ctx context.Context, publicKey []byte, project *Project) (*ProjectDeployKey, error)

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

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

+ type CodeRepoAndProject struct

+ CodeRepo *resourcev1alpha1.CodeRepo

+ Project *Project

+ type CodeRepoData struct

+ Name string

+ Spec resourcev1alpha1.CodeRepoSpec

+ type CodeRepoUsecase struct

+ func NewCodeRepoUsecase(logger log.Logger, codeRepo CodeRepo, secretRepo Secretrepo, ...) *CodeRepoUsecase

+ func (c *CodeRepoUsecase) AddDeployKeyAndRemoveInvalidDeployKey(ctx context.Context, project *Project) error

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

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

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

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

+ func (c *CodeRepoUsecase) GetCodeRepo(ctx context.Context, codeRepoName, productName string) (*resourcev1alpha1.CodeRepo, *Project, error)

+ func (c *CodeRepoUsecase) GetDeployKeyFromSecretRepo(ctx context.Context, repoName string) (*DeployKeySecretData, error)

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

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

+ func (c *CodeRepoUsecase) SaveDeployKey(ctx context.Context, pid interface{}, project *Project) error

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

+ type DeployKeySecretData struct

+ Fingerprint string

+ ID int

+ type DeploymentRuntimeData struct

+ Name string

+ Spec resourcev1alpha1.DeploymentRuntimeSpec

+ type DeploymentRuntimeUsecase struct

+ func NewDeploymentRuntimeUsecase(logger log.Logger, codeRepo CodeRepo, nodestree nodestree.NodesTree, ...) *DeploymentRuntimeUsecase

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

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

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

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

+ func (d *DeploymentRuntimeUsecase) ListDeploymentRuntimes(ctx context.Context, productName string) ([]*resourcev1alpha1.DeploymentRuntime, error)

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

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

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

+ type DexRepo interface

+ RemoveRedirectURIs func(redirectURIs string) error

+ UpdateRedirectURIs func(redirectURI string) error

+ type EnviromentData struct

+ Name string

+ Spec resourcev1alpha1.EnvironmentSpec

+ type EnvironmentUsecase struct

+ func NewEnviromentUsecase(logger log.Logger, config *nautesconfigs.Config, codeRepo CodeRepo, ...) *EnvironmentUsecase

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

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

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

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

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

+ func (e *EnvironmentUsecase) ListEnvironments(ctx context.Context, productName string) ([]*resourcev1alpha1.Environment, error)

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

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

+ type GitCodeRepoOptions struct

+ Github interface{}

+ Gitlab *GitlabCodeRepoOptions

+ type GitGroupOptions struct

+ Github *GroupOptions

+ Gitlab *GroupOptions

+ type GitRepo interface

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

+ Commit func(path, message string) error

+ Diff func(ctx context.Context, path string, command ...string) (string, error)

+ Fetch func(ctx context.Context, path string, command ...string) (string, error)

+ Merge func(ctx context.Context, path string) (string, error)

+ Push func(ctx context.Context, path string, command ...string) error

+ SaveConfig func(ctx context.Context, path string) error

+ type GitlabCodeRepoOptions struct

+ Description string

+ Name string

+ NamespaceID int32

+ Path string

+ Visibility string

+ type Group struct

+ Description string

+ Id int32

+ Name string

+ ParentId int32

+ Path string

+ Visibility string

+ WebUrl string

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

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

+ func UpdateGroup(ctx context.Context, codeRepo CodeRepo, configClient *nautesconfigs.Config, ...) (group *Group, err error)

+ type GroupAndProjectItem struct

+ Group *Group

+ Project *Project

+ type GroupOptions struct

+ Description string

+ Name string

+ ParentId int32

+ Path string

+ Visibility string

+ type ListOptions struct

+ Page int

+ PerPage int

+ type MockCodeRepo struct

+ func NewMockCodeRepo(ctrl *gomock.Controller) *MockCodeRepo

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

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

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

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

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

+ func (m *MockCodeRepo) EXPECT() *MockCodeRepoMockRecorder

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

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

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

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

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

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

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

+ func (m *MockCodeRepo) SaveDeployKey(ctx context.Context, publicKey []byte, project *Project) (*ProjectDeployKey, error)

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

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

+ type MockCodeRepoMockRecorder struct

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

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

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

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

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

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

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

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

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

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

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

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

+ func (mr *MockCodeRepoMockRecorder) SaveDeployKey(ctx, publicKey, project interface{}) *gomock.Call

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

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

+ type MockDexRepo struct

+ func NewMockDexRepo(ctrl *gomock.Controller) *MockDexRepo

+ func (m *MockDexRepo) EXPECT() *MockDexRepoMockRecorder

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

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

+ type MockDexRepoMockRecorder struct

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

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

+ type MockGitRepo struct

+ func NewMockGitRepo(ctrl *gomock.Controller) *MockGitRepo

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

+ func (m *MockGitRepo) Commit(path, message string) error

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

+ func (m *MockGitRepo) EXPECT() *MockGitRepoMockRecorder

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

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

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

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

+ type MockGitRepoMockRecorder struct

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

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

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

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

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

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

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

+ type MockSecretrepo struct

+ func NewMockSecretrepo(ctrl *gomock.Controller) *MockSecretrepo

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

+ func (m *MockSecretrepo) DeleteSecret(ctx context.Context, id int) error

+ func (m *MockSecretrepo) EXPECT() *MockSecretrepoMockRecorder

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

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

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

+ func (m *MockSecretrepo) SaveDeployKey(ctx context.Context, id int, key string, extendKVs map[string]string) error

+ type MockSecretrepoMockRecorder struct

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

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

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

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

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

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

+ type ProductUsecase struct

+ func NewProductUsecase(logger log.Logger, codeRepo CodeRepo, secretRepo Secretrepo, gitRepo GitRepo, ...) *ProductUsecase

+ func (p *ProductUsecase) AddDeployKey(ctx context.Context, project *Project, publicKey, privateKey []byte) error

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

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

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

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

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

+ type Project struct

+ Description string

+ HttpUrlToRepo string

+ Id int32

+ Name string

+ Path string

+ PathWithNamespace string

+ SshUrlToRepo string

+ Visibility string

+ WebUrl string

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

+ type ProjectData struct

+ Language string

+ ProductName string

+ ProjectName string

+ type ProjectDeployKey struct

+ CanPush bool

+ CreatedAt *time.Time

+ ID int

+ Key string

+ Title string

+ type ProjectPipelineRuntimeData struct

+ Name string

+ Spec resourcev1alpha1.ProjectPipelineRuntimeSpec

+ type ProjectPipelineRuntimeUsecase struct

+ func NewProjectPipelineRuntimeUsecase(logger log.Logger, codeRepo CodeRepo, nodestree nodestree.NodesTree, ...) *ProjectPipelineRuntimeUsecase

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

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

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

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

+ func (p *ProjectPipelineRuntimeUsecase) GetProjectPipelineRuntime(ctx context.Context, projectPipelineName, productName string) (*resourcev1alpha1.ProjectPipelineRuntime, error)

+ func (p *ProjectPipelineRuntimeUsecase) ListProjectPipelineRuntimes(ctx context.Context, productName string) ([]*resourcev1alpha1.ProjectPipelineRuntime, error)

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

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

+ type ProjectUsecase struct

+ func NewProjectUsecase(logger log.Logger, codeRepo CodeRepo, secretRepo Secretrepo, ...) *ProjectUsecase

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

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

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

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

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

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

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

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

+ type ResourcesUsecase struct

+ func NewResourcesUsecase(log log.Logger, codeRepo CodeRepo, secretRepo Secretrepo, gitRepo GitRepo, ...) *ResourcesUsecase

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

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

+ func (r *ResourcesUsecase) Get(ctx context.Context, resourceKind, productName string, ...) (*nodestree.Node, error)

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

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

+ func (r *ResourcesUsecase) GetProductAndCodeRepo(ctx context.Context, ProductName string) (*Group, *Project, error)

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

+ func (r *ResourcesUsecase) List(ctx context.Context, productName string, operator nodestree.NodesOperator) (*nodestree.Node, error)

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

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

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

+ func (r *ResourcesUsecase) SaveDeployConfig(nodes *nodestree.Node, path string) error

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

+ type RretryCountType string

+ const KustomizationFileName

+ const RretryCount

+ type SecretData struct

+ Data string

+ ID int

+ type SecretOptions struct

+ SecretEngine string

+ SecretKey string

+ SecretPath string

+ type Secretrepo interface

+ AuthorizationSecret func(ctx context.Context, id int, destUser string) error

+ DeleteSecret func(ctx context.Context, id int) error

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

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

+ SaveClusterConfig func(ctx context.Context, id, config string) error

+ SaveDeployKey func(ctx context.Context, id int, key string, extendKVs map[string]string) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL