repo

package

Go to main page

Versions in this module

v5

v5.0.13

Nov 7, 2024

Changes in this version

type MockRepoRepo

+ func (m *MockRepoRepo) Get(arg0 context.Context, arg1 int) (*Repo, error)

type MockRepoRepoMockRecorder

+ func (mr *MockRepoRepoMockRecorder) Get(arg0, arg1 any) *gomock.Call

type RepoRepo

+ Get func(ctx context.Context, id int) (*Repo, error)

v5.0.12

Oct 16, 2024

v5.0.11

Oct 16, 2024

v5.0.10

Oct 10, 2024

v5.0.9

Sep 19, 2024

v5.0.8

Sep 18, 2024

v5.0.7

Sep 18, 2024

Changes in this version

type MockProjectRepo

+ func (m *MockProjectRepo) Version(arg0 context.Context, arg1 int) (int, error)

type MockProjectRepoMockRecorder

+ func (mr *MockProjectRepoMockRecorder) Version(arg0, arg1 any) *gomock.Call

type ProjectRepo

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

v5.0.6

Sep 14, 2024

v5.0.5

Sep 13, 2024

v5.0.4

Sep 12, 2024

v5.0.3

Sep 11, 2024

v5.0.2

Sep 11, 2024

v5.0.1

Sep 11, 2024

v5.0.0

Sep 11, 2024

Changes in this version

+ const AuditLogEvent

+ const EventNamespaceCreated

+ const EventNamespaceDeleted

+ const EventProjectChanged

+ const EventProjectDeleted

+ const RevisionAnnotation

+ const StatusDeployed

+ const StatusFailed

+ const StatusPending

+ const StatusUnknown

+ const StreamUploadFileDisk

+ var DirSizeCacheSeconds = int((15 * time.Minute).Seconds())

+ var WireRepoSet = wire.NewSet(NewCronRepo, NewAuthRepo, NewK8sRepo, NewDefaultHelmer, NewRepo, ...)

+ func IsRemoteLocalChartPath(input string) bool

+ func ToError(code uint32, err any) error

+ type AccessToken struct

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ Email string

+ ExpiredAt time.Time

+ ID int

+ LastUsedAt *time.Time

+ Token string

+ UpdatedAt time.Time

+ Usage string

+ UserInfo schematype.UserInfo

+ func ToAccessToken(token *ent.AccessToken) *AccessToken

+ func (at *AccessToken) Expired() bool

+ type AccessTokenRepo interface

+ Grant func(ctx context.Context, input *GrantAccessTokenInput) (*AccessToken, error)

+ Lease func(ctx context.Context, token string, expireSeconds int32) (*AccessToken, error)

+ List func(ctx context.Context, input *ListAccessTokenInput) ([]*AccessToken, *pagination.Pagination, error)

+ Revoke func(ctx context.Context, token string) error

+ func NewAccessTokenRepo(timer timer.Timer, logger mlog.Logger, data data.Data) AccessTokenRepo

+ type AllRepoRequest struct

+ Enabled *bool

+ NeedGitRepo *bool

+ OrderByIDDesc *bool

+ type AnyYamlPrettier map[string]any

+ func (s *AnyYamlPrettier) PrettyYaml() string

+ type Archiver interface

+ Archive func(sources []string, destination string) error

+ Open func(path string) (io.ReadCloser, error)

+ Remove func(path string) error

+ func NewDefaultArchiver() Archiver

+ type AuditLog interface

+ GetAction func() types.EventActionType

+ GetDuration func() string

+ GetFileID func() int

+ GetMsg func() string

+ GetNewStr func() string

+ GetOldStr func() string

+ GetUsername func() string

+ func NewEventAuditLog(username string, action types.EventActionType, msg string, opts ...AuditOption) AuditLog

+ type AuditOption func(*auditLogImpl)

+ func AuditWithDuration(d string) AuditOption

+ func AuditWithFileID(id int) AuditOption

+ func AuditWithOldNew(o, n YamlPrettier) AuditOption

+ func AuditWithOldNewStr(o, n string) AuditOption

+ type AuthRepo interface

+ Login func(ctx context.Context, input *LoginInput) (*LoginResponse, error)

+ Settings func(ctx context.Context) (data.OidcConfig, error)

+ Sign func(ctx context.Context, input *auth2.UserInfo) (*LoginResponse, error)

+ VerifyToken func(ctx context.Context, token string) (*auth2.UserInfo, error)

+ func NewAuthRepo(authsvc auth2.Auth, logger mlog.Logger, data data.Data) AuthRepo

+ type Branch struct

+ IsDefault bool

+ Name string

+ WebURL string

+ type Changelog struct

+ Config string

+ ConfigChanged bool

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ DockerImage []string

+ EnvValues []*types.KeyValue

+ ExtraValues []*websocket_pb.ExtraValue

+ FinalExtraValues []*websocket_pb.ExtraValue

+ GitBranch string

+ GitCommit string

+ GitCommitAuthor string

+ GitCommitDate *time.Time

+ GitCommitTitle string

+ GitCommitWebURL string

+ ID int

+ Project *Project

+ ProjectID int

+ UpdatedAt time.Time

+ Username string

+ Version int

+ func ToChangeLog(c *ent.Changelog) *Changelog

+ type ChangelogRepo interface

+ Create func(ctx context.Context, input *CreateChangeLogInput) (*Changelog, error)

+ FindLastChangeByProjectID func(ctx context.Context, projectID int) (*Changelog, error)

+ FindLastChangelogsByProjectID func(ctx context.Context, input *FindLastChangelogsByProjectIDChangeLogInput) ([]*Changelog, error)

+ func NewChangelogRepo(logger mlog.Logger, data data.Data) ChangelogRepo

+ type CloneRepoInput struct

+ ID int

+ Name string

+ type ClusterInfo struct

+ FreeCpu string

+ FreeMemory string

+ FreeRequestCpu string

+ FreeRequestMemory string

+ RequestCpuRate string

+ RequestMemoryRate string

+ Status ClusterStatus

+ TotalCpu string

+ TotalMemory string

+ UsageCpuRate string

+ UsageMemoryRate string

+ type ClusterStatus = string

+ const StatusBad

+ const StatusHealth

+ const StatusNotGood

+ type Commit struct

+ AuthorEmail string

+ AuthorName string

+ CommittedDate *time.Time

+ CommitterEmail string

+ CommitterName string

+ CreatedAt *time.Time

+ ID string

+ Message string

+ ShortID string

+ Title string

+ WebURL string

+ func ToCommit(v application.Commit) *Commit

+ type Container struct

+ Container string

+ Namespace string

+ Pod string

+ type CopyFileToPodInput struct

+ Container string

+ FileId int64

+ Namespace string

+ Pod string

+ type CopyFromPodInput struct

+ Container string

+ FilePath string

+ Namespace string

+ Pod string

+ UserName string

+ type CreateChangeLogInput struct

+ Config string

+ ConfigChanged bool

+ DockerImage []string

+ EnvValues []*types.KeyValue

+ ExtraValues []*websocket_pb.ExtraValue

+ FinalExtraValues []*websocket_pb.ExtraValue

+ GitBranch string

+ GitCommit string

+ GitCommitAuthor string

+ GitCommitDate *time.Time

+ GitCommitTitle string

+ GitCommitWebURL string

+ ProjectID int

+ Username string

+ Version int

+ type CreateFileInput struct

+ Container string

+ Namespace string

+ Path string

+ Pod string

+ Size uint64

+ UploadType schematype.UploadType

+ Username string

+ type CreateNamespaceInput struct

+ CreatorEmail string

+ Description string

+ ImagePullSecrets []string

+ Name string

+ type CreateProjectInput struct

+ Atomic *bool

+ Config string

+ ConfigType string

+ Creator string

+ DeployStatus types.Deploy

+ GitBranch string

+ GitCommit string

+ GitProjectID int

+ Name string

+ NamespaceID int

+ PodSelectors []string

+ RepoID int

+ type CreateRepoInput struct

+ Description string

+ Enabled bool

+ GitProjectID *int32

+ MarsConfig *mars.Config

+ Name string

+ NeedGitRepo bool

+ type CronRepo interface

+ CacheAllBranches func() error

+ CleanUploadFiles func() error

+ DiskInfo func() (int64, error)

+ FixDeployStatus func() error

+ SyncImagePullSecrets func() error

+ func NewCronRepo(logger mlog.Logger, fileRepo FileRepo, cache cache.Cache, repoRepo RepoRepo, ...) CronRepo

+ type DefaultHelmer struct

+ Debug bool

+ DockerAuth config.DockerAuths

+ KubeConfig string

+ func (d *DefaultHelmer) PackageChart(path string, destDir string) (string, error)

+ func (d *DefaultHelmer) ReleaseStatus(releaseName, namespace string) types.Deploy

+ func (d *DefaultHelmer) Rollback(releaseName, namespace string, wait bool, log LogFn, dryRun bool) error

+ func (d *DefaultHelmer) Uninstall(releaseName, namespace string, log LogFn) error

+ func (d *DefaultHelmer) UpgradeOrInstall(ctx context.Context, releaseName, namespace string, ch *chart.Chart, ...) (*release.Release, error)

+ type DockerConfig map[string]DockerConfigEntry

+ type DockerConfigEntry struct

+ Auth string

+ Email string

+ Password string

+ Username string

+ type DockerConfigJSON struct

+ Auths DockerConfig

+ HttpHeaders map[string]string

+ type EndpointMapping map[string][]*types.ServiceEndpoint

+ func (e EndpointMapping) AllEndpoints() []*types.ServiceEndpoint

+ func (e EndpointMapping) Get(projName string) []*types.ServiceEndpoint

+ func (e EndpointMapping) Sort()

+ type EndpointRepo interface

+ InNamespace func(ctx context.Context, namespaceID int) (res []*types.ServiceEndpoint, err error)

+ InProject func(ctx context.Context, projectID int) (res []*types.ServiceEndpoint, err error)

+ func NewEndpointRepo(logger mlog.Logger, data data.Data, projRepo ProjectRepo, nsRepo NamespaceRepo) EndpointRepo

+ type Event struct

+ Action types.EventActionType

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ Duration string

+ File *File

+ FileID *int

+ HasDiff bool

+ ID int

+ Message string

+ New string

+ Old string

+ UpdatedAt time.Time

+ Username string

+ func ToEvent(data *ent.Event) *Event

+ type EventRepo interface

+ AuditLog func(action types.EventActionType, username string, msg string)

+ AuditLogWithChange func(action types.EventActionType, username string, msg string, ...)

+ AuditLogWithRequest func(action types.EventActionType, username string, msg string, req any)

+ Dispatch func(created event.Event, createdData any)

+ FileAuditLog func(action types.EventActionType, username string, msg string, fileId int)

+ FileAuditLogWithDuration func(action types.EventActionType, username string, msg string, fileId int, ...)

+ HandleAuditLog func(data any, e event.Event) error

+ List func(ctx context.Context, input *ListEventInput) (events []*Event, pag *pagination.Pagination, err error)

+ Show func(ctx context.Context, id int) (*Event, error)

+ func NewEventRepo(projectRepo ProjectRepo, k8sRepo K8sRepo, pl application.PluginManger, ...) EventRepo

+ type ExecuteInput struct

+ Cmd []string

+ Stderr io.Writer

+ Stdin io.Reader

+ Stdout io.Writer

+ TTY bool

+ TerminalSizeQueue remotecommand.TerminalSizeQueue

+ type Executor interface

+ Execute func(context.Context, *ExecuteInput) error

+ WithCommand func(cmd []string) Executor

+ WithContainer func(namespace, pod, container string) Executor

+ WithMethod func(method string) Executor

+ type ExecutorManager interface

+ New func() Executor

+ NewFileCopy func(maxTries int, errOut io.Writer) k8s.FileCopy

+ func NewExecutorManager(data data.Data, logger mlog.Logger) ExecutorManager

+ type Favorite struct

+ Email string

+ ID int

+ NamespaceID int

+ func ToFavorite(v *ent.Favorite) *Favorite

+ type FavoriteNamespaceInput struct

+ Favorite bool

+ NamespaceID int

+ UserEmail string

+ type File struct

+ Container string

+ ContainerPath string

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ HumanizeSize string

+ ID int

+ Namespace string

+ Path string

+ Pod string

+ Size uint64

+ UpdatedAt time.Time

+ UploadType schematype.UploadType

+ Username string

+ func ToFile(file *ent.File) *File

+ type FileRepo interface

+ Create func(todo context.Context, input *CreateFileInput) (*File, error)

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

+ DiskInfo func(force bool) (int64, error)

+ GetByID func(ctx context.Context, id int) (*File, error)

+ List func(ctx context.Context, input *ListFileInput) ([]*File, *pagination.Pagination, error)

+ MaxUploadSize func() uint64

+ NewDisk func(disk string) uploader.Uploader

+ NewFile func(fpath string) (uploader.File, error)

+ NewRecorder func(user *auth.UserInfo, container *Container) Recorder

+ ShowRecords func(ctx context.Context, id int) (io.ReadCloser, error)

+ StreamUploadFile func(ctx context.Context, input *StreamUploadFileRequest) (*File, error)

+ Update func(ctx context.Context, i *UpdateFileRequest) (*File, error)

+ func NewFileRepo(logger mlog.Logger, data data.Data, cache cache.Cache, ...) FileRepo

+ type FindLastChangelogsByProjectIDChangeLogInput struct

+ Limit int

+ OnlyChanged bool

+ OrderByVersionDesc *bool

+ ProjectID int

+ type GitProject struct

+ AvatarURL string

+ DefaultBranch string

+ Description string

+ ID int64

+ Name string

+ Path string

+ WebURL string

+ func ToGitProject(gp application.Project) *GitProject

+ type GitRepo interface

+ AllBranches func(ctx context.Context, projectID int, forceFresh bool) (branches []*Branch, err error)

+ AllProjects func(ctx context.Context, forceFresh bool) (projects []*GitProject, err error)

+ GetByProjectID func(ctx context.Context, id int) (project *GitProject, err error)

+ GetChartValuesYaml func(ctx context.Context, localChartPath string) (string, error)

+ GetCommit func(ctx context.Context, projectID int, sha string) (*Commit, error)

+ GetCommitPipeline func(ctx context.Context, projectID int, branch, sha string) (*Pipeline, error)

+ GetFileContentWithBranch func(ctx context.Context, projectID int, branch, path string) (string, error)

+ GetProject func(ctx context.Context, id int) (project *GitProject, err error)

+ ListCommits func(ctx context.Context, projectID int, branch string) ([]*Commit, error)

+ func NewGitRepo(logger mlog.Logger, cache cache.Cache, pl application.PluginManger, ...) GitRepo

+ type GrantAccessTokenInput struct

+ ExpireSeconds int32

+ Usage string

+ User *auth.UserInfo

+ type HelmerRepo interface

+ PackageChart func(path string, destDir string) (string, error)

+ ReleaseStatus func(releaseName, namespace string) types.Deploy

+ Rollback func(releaseName, namespace string, wait bool, log LogFn, dryRun bool) error

+ Uninstall func(releaseName, namespace string, log LogFn) error

+ UpgradeOrInstall func(ctx context.Context, releaseName, namespace string, ch *chart.Chart, ...) (*release.Release, error)

+ func NewDefaultHelmer(k8sRepo K8sRepo, data data.Data, cfg *config.Config, logger mlog.Logger) HelmerRepo

+ type K8sRepo interface

+ AddTlsSecret func(ns string, name string, key string, crt string) (*corev1.Secret, error)

+ ClusterInfo func() *ClusterInfo

+ CopyFileToPod func(ctx context.Context, input *CopyFileToPodInput) (*File, error)

+ CopyFromPod func(ctx context.Context, input *CopyFromPodInput) (*File, error)

+ CreateDockerSecret func(ctx context.Context, namespace string) (*corev1.Secret, error)

+ CreateNamespace func(ctx context.Context, name string) (*corev1.Namespace, error)

+ DeleteNamespace func(ctx context.Context, name string) error

+ DeleteSecret func(ctx context.Context, namespace, secret string) error

+ Execute func(ctx context.Context, c *Container, input *ExecuteInput) error

+ FindDefaultContainer func(ctx context.Context, namespace string, pod string) (string, error)

+ GetAllPodMetrics func(ctx context.Context, proj *Project) []v1beta1.PodMetrics

+ GetCpuAndMemory func(ctx context.Context, list []v1beta1.PodMetrics) (string, string)

+ GetCpuAndMemoryInNamespace func(ctx context.Context, namespace string) (string, string)

+ GetCpuAndMemoryQuantity func(pod v1beta1.PodMetrics) (cpu *resource.Quantity, memory *resource.Quantity)

+ GetNamespace func(ctx context.Context, name string) (*corev1.Namespace, error)

+ GetPod func(namespace, podName string) (*corev1.Pod, error)

+ GetPodLogs func(ctx context.Context, namespace, podName string, options *corev1.PodLogOptions) (string, error)

+ GetPodMetrics func(ctx context.Context, namespace, podName string) (*v1beta1.PodMetrics, error)

+ GetPodSelectorsByManifest func(manifests []string) []string

+ IsPodRunning func(namespace, podName string) (running bool, notRunningReason string)

+ ListEvents func(namespace string) ([]*eventv1.Event, error)

+ LogStream func(ctx context.Context, namespace, pod, container string) (chan []byte, error)

+ SplitManifests func(manifest string) []string

+ func NewK8sRepo(logger mlog.Logger, timer timer.Timer, data data.Data, fileRepo FileRepo, ...) K8sRepo

+ type ListAccessTokenInput struct

+ Email string

+ Page int32

+ PageSize int32

+ WithSoftDelete bool

+ type ListEventInput struct

+ ActionType types.EventActionType

+ OrderIDDesc *bool

+ Page int32

+ PageSize int32

+ Search string

+ type ListFileInput struct

+ OrderIDDesc *bool

+ Page int32

+ PageSize int32

+ WithSoftDelete bool

+ type ListNamespaceInput struct

+ Email string

+ Favorite bool

+ IsAdmin bool

+ Name *string

+ Page int32

+ PageSize int32

+ type ListProjectInput struct

+ OrderByIDDesc *bool

+ Page int32

+ PageSize int32

+ type ListReleaseItem struct

+ Release *release.Release

+ Status string

+ type ListRepoRequest struct

+ Enabled *bool

+ Name string

+ OrderByIDDesc *bool

+ Page int32

+ PageSize int32

+ type LogFn func(format string, v ...any)

+ type LoginInput struct

+ Password string

+ Username string

+ type LoginResponse struct

+ ExpiredIn int64

+ Token string

+ UserInfo *auth2.UserInfo

+ type Member struct

+ Email string

+ ID int

+ NamespaceID int

+ func ToMember(v *ent.Member) *Member

+ type MockAccessTokenRepo struct

+ func NewMockAccessTokenRepo(ctrl *gomock.Controller) *MockAccessTokenRepo

+ func (m *MockAccessTokenRepo) EXPECT() *MockAccessTokenRepoMockRecorder

+ func (m *MockAccessTokenRepo) Grant(arg0 context.Context, arg1 *GrantAccessTokenInput) (*AccessToken, error)

+ func (m *MockAccessTokenRepo) Lease(arg0 context.Context, arg1 string, arg2 int32) (*AccessToken, error)

+ func (m *MockAccessTokenRepo) List(arg0 context.Context, arg1 *ListAccessTokenInput) ([]*AccessToken, *pagination.Pagination, error)

+ func (m *MockAccessTokenRepo) Revoke(arg0 context.Context, arg1 string) error

+ type MockAccessTokenRepoMockRecorder struct

+ func (mr *MockAccessTokenRepoMockRecorder) Grant(arg0, arg1 any) *gomock.Call

+ func (mr *MockAccessTokenRepoMockRecorder) Lease(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockAccessTokenRepoMockRecorder) List(arg0, arg1 any) *gomock.Call

+ func (mr *MockAccessTokenRepoMockRecorder) Revoke(arg0, arg1 any) *gomock.Call

+ type MockAuthRepo struct

+ func NewMockAuthRepo(ctrl *gomock.Controller) *MockAuthRepo

+ func (m *MockAuthRepo) EXPECT() *MockAuthRepoMockRecorder

+ func (m *MockAuthRepo) Login(arg0 context.Context, arg1 *LoginInput) (*LoginResponse, error)

+ func (m *MockAuthRepo) Settings(arg0 context.Context) (data.OidcConfig, error)

+ func (m *MockAuthRepo) Sign(arg0 context.Context, arg1 *schematype.UserInfo) (*LoginResponse, error)

+ func (m *MockAuthRepo) VerifyToken(arg0 context.Context, arg1 string) (*schematype.UserInfo, error)

+ type MockAuthRepoMockRecorder struct

+ func (mr *MockAuthRepoMockRecorder) Login(arg0, arg1 any) *gomock.Call

+ func (mr *MockAuthRepoMockRecorder) Settings(arg0 any) *gomock.Call

+ func (mr *MockAuthRepoMockRecorder) Sign(arg0, arg1 any) *gomock.Call

+ func (mr *MockAuthRepoMockRecorder) VerifyToken(arg0, arg1 any) *gomock.Call

+ type MockChangelogRepo struct

+ func NewMockChangelogRepo(ctrl *gomock.Controller) *MockChangelogRepo

+ func (m *MockChangelogRepo) Create(arg0 context.Context, arg1 *CreateChangeLogInput) (*Changelog, error)

+ func (m *MockChangelogRepo) EXPECT() *MockChangelogRepoMockRecorder

+ func (m *MockChangelogRepo) FindLastChangeByProjectID(arg0 context.Context, arg1 int) (*Changelog, error)

+ func (m *MockChangelogRepo) FindLastChangelogsByProjectID(arg0 context.Context, arg1 *FindLastChangelogsByProjectIDChangeLogInput) ([]*Changelog, error)

+ type MockChangelogRepoMockRecorder struct

+ func (mr *MockChangelogRepoMockRecorder) Create(arg0, arg1 any) *gomock.Call

+ func (mr *MockChangelogRepoMockRecorder) FindLastChangeByProjectID(arg0, arg1 any) *gomock.Call

+ func (mr *MockChangelogRepoMockRecorder) FindLastChangelogsByProjectID(arg0, arg1 any) *gomock.Call

+ type MockEndpointRepo struct

+ func NewMockEndpointRepo(ctrl *gomock.Controller) *MockEndpointRepo

+ func (m *MockEndpointRepo) EXPECT() *MockEndpointRepoMockRecorder

+ func (m *MockEndpointRepo) InNamespace(arg0 context.Context, arg1 int) ([]*types.ServiceEndpoint, error)

+ func (m *MockEndpointRepo) InProject(arg0 context.Context, arg1 int) ([]*types.ServiceEndpoint, error)

+ type MockEndpointRepoMockRecorder struct

+ func (mr *MockEndpointRepoMockRecorder) InNamespace(arg0, arg1 any) *gomock.Call

+ func (mr *MockEndpointRepoMockRecorder) InProject(arg0, arg1 any) *gomock.Call

+ type MockEventRepo struct

+ func NewMockEventRepo(ctrl *gomock.Controller) *MockEventRepo

+ func (m *MockEventRepo) AuditLog(arg0 types.EventActionType, arg1, arg2 string)

+ func (m *MockEventRepo) AuditLogWithChange(arg0 types.EventActionType, arg1, arg2 string, arg3, arg4 YamlPrettier)

+ func (m *MockEventRepo) AuditLogWithRequest(arg0 types.EventActionType, arg1, arg2 string, arg3 any)

+ func (m *MockEventRepo) Dispatch(arg0 event.Event, arg1 any)

+ func (m *MockEventRepo) EXPECT() *MockEventRepoMockRecorder

+ func (m *MockEventRepo) FileAuditLog(arg0 types.EventActionType, arg1, arg2 string, arg3 int)

+ func (m *MockEventRepo) FileAuditLogWithDuration(arg0 types.EventActionType, arg1, arg2 string, arg3 int, arg4 time.Duration)

+ func (m *MockEventRepo) HandleAuditLog(arg0 any, arg1 event.Event) error

+ func (m *MockEventRepo) List(arg0 context.Context, arg1 *ListEventInput) ([]*Event, *pagination.Pagination, error)

+ func (m *MockEventRepo) Show(arg0 context.Context, arg1 int) (*Event, error)

+ type MockEventRepoMockRecorder struct

+ func (mr *MockEventRepoMockRecorder) AuditLog(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockEventRepoMockRecorder) AuditLogWithChange(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call

+ func (mr *MockEventRepoMockRecorder) AuditLogWithRequest(arg0, arg1, arg2, arg3 any) *gomock.Call

+ func (mr *MockEventRepoMockRecorder) Dispatch(arg0, arg1 any) *gomock.Call

+ func (mr *MockEventRepoMockRecorder) FileAuditLog(arg0, arg1, arg2, arg3 any) *gomock.Call

+ func (mr *MockEventRepoMockRecorder) FileAuditLogWithDuration(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call

+ func (mr *MockEventRepoMockRecorder) HandleAuditLog(arg0, arg1 any) *gomock.Call

+ func (mr *MockEventRepoMockRecorder) List(arg0, arg1 any) *gomock.Call

+ func (mr *MockEventRepoMockRecorder) Show(arg0, arg1 any) *gomock.Call

+ type MockExecutor struct

+ func NewMockExecutor(ctrl *gomock.Controller) *MockExecutor

+ func (m *MockExecutor) EXPECT() *MockExecutorMockRecorder

+ func (m *MockExecutor) Execute(arg0 context.Context, arg1 *ExecuteInput) error

+ func (m *MockExecutor) WithCommand(arg0 []string) Executor

+ func (m *MockExecutor) WithContainer(arg0, arg1, arg2 string) Executor

+ func (m *MockExecutor) WithMethod(arg0 string) Executor

+ type MockExecutorManager struct

+ func NewMockExecutorManager(ctrl *gomock.Controller) *MockExecutorManager

+ func (m *MockExecutorManager) EXPECT() *MockExecutorManagerMockRecorder

+ func (m *MockExecutorManager) New() Executor

+ func (m *MockExecutorManager) NewFileCopy(arg0 int, arg1 io.Writer) k8s.FileCopy

+ type MockExecutorManagerMockRecorder struct

+ func (mr *MockExecutorManagerMockRecorder) New() *gomock.Call

+ func (mr *MockExecutorManagerMockRecorder) NewFileCopy(arg0, arg1 any) *gomock.Call

+ type MockExecutorMockRecorder struct

+ func (mr *MockExecutorMockRecorder) Execute(arg0, arg1 any) *gomock.Call

+ func (mr *MockExecutorMockRecorder) WithCommand(arg0 any) *gomock.Call

+ func (mr *MockExecutorMockRecorder) WithContainer(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockExecutorMockRecorder) WithMethod(arg0 any) *gomock.Call

+ type MockFileRepo struct

+ func NewMockFileRepo(ctrl *gomock.Controller) *MockFileRepo

+ func (m *MockFileRepo) Create(arg0 context.Context, arg1 *CreateFileInput) (*File, error)

+ func (m *MockFileRepo) Delete(arg0 context.Context, arg1 int) error

+ func (m *MockFileRepo) DiskInfo(arg0 bool) (int64, error)

+ func (m *MockFileRepo) EXPECT() *MockFileRepoMockRecorder

+ func (m *MockFileRepo) GetByID(arg0 context.Context, arg1 int) (*File, error)

+ func (m *MockFileRepo) List(arg0 context.Context, arg1 *ListFileInput) ([]*File, *pagination.Pagination, error)

+ func (m *MockFileRepo) MaxUploadSize() uint64

+ func (m *MockFileRepo) NewDisk(arg0 string) uploader.Uploader

+ func (m *MockFileRepo) NewFile(arg0 string) (uploader.File, error)

+ func (m *MockFileRepo) NewRecorder(arg0 *schematype.UserInfo, arg1 *Container) Recorder

+ func (m *MockFileRepo) ShowRecords(arg0 context.Context, arg1 int) (io.ReadCloser, error)

+ func (m *MockFileRepo) StreamUploadFile(arg0 context.Context, arg1 *StreamUploadFileRequest) (*File, error)

+ func (m *MockFileRepo) Update(arg0 context.Context, arg1 *UpdateFileRequest) (*File, error)

+ type MockFileRepoMockRecorder struct

+ func (mr *MockFileRepoMockRecorder) Create(arg0, arg1 any) *gomock.Call

+ func (mr *MockFileRepoMockRecorder) Delete(arg0, arg1 any) *gomock.Call

+ func (mr *MockFileRepoMockRecorder) DiskInfo(arg0 any) *gomock.Call

+ func (mr *MockFileRepoMockRecorder) GetByID(arg0, arg1 any) *gomock.Call

+ func (mr *MockFileRepoMockRecorder) List(arg0, arg1 any) *gomock.Call

+ func (mr *MockFileRepoMockRecorder) MaxUploadSize() *gomock.Call

+ func (mr *MockFileRepoMockRecorder) NewDisk(arg0 any) *gomock.Call

+ func (mr *MockFileRepoMockRecorder) NewFile(arg0 any) *gomock.Call

+ func (mr *MockFileRepoMockRecorder) NewRecorder(arg0, arg1 any) *gomock.Call

+ func (mr *MockFileRepoMockRecorder) ShowRecords(arg0, arg1 any) *gomock.Call

+ func (mr *MockFileRepoMockRecorder) StreamUploadFile(arg0, arg1 any) *gomock.Call

+ func (mr *MockFileRepoMockRecorder) Update(arg0, arg1 any) *gomock.Call

+ type MockGitRepo struct

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

+ func (m *MockGitRepo) AllBranches(arg0 context.Context, arg1 int, arg2 bool) ([]*Branch, error)

+ func (m *MockGitRepo) AllProjects(arg0 context.Context, arg1 bool) ([]*GitProject, error)

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

+ func (m *MockGitRepo) GetByProjectID(arg0 context.Context, arg1 int) (*GitProject, error)

+ func (m *MockGitRepo) GetChartValuesYaml(arg0 context.Context, arg1 string) (string, error)

+ func (m *MockGitRepo) GetCommit(arg0 context.Context, arg1 int, arg2 string) (*Commit, error)

+ func (m *MockGitRepo) GetCommitPipeline(arg0 context.Context, arg1 int, arg2, arg3 string) (*Pipeline, error)

+ func (m *MockGitRepo) GetFileContentWithBranch(arg0 context.Context, arg1 int, arg2, arg3 string) (string, error)

+ func (m *MockGitRepo) GetProject(arg0 context.Context, arg1 int) (*GitProject, error)

+ func (m *MockGitRepo) ListCommits(arg0 context.Context, arg1 int, arg2 string) ([]*Commit, error)

+ type MockGitRepoMockRecorder struct

+ func (mr *MockGitRepoMockRecorder) AllBranches(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockGitRepoMockRecorder) AllProjects(arg0, arg1 any) *gomock.Call

+ func (mr *MockGitRepoMockRecorder) GetByProjectID(arg0, arg1 any) *gomock.Call

+ func (mr *MockGitRepoMockRecorder) GetChartValuesYaml(arg0, arg1 any) *gomock.Call

+ func (mr *MockGitRepoMockRecorder) GetCommit(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockGitRepoMockRecorder) GetCommitPipeline(arg0, arg1, arg2, arg3 any) *gomock.Call

+ func (mr *MockGitRepoMockRecorder) GetFileContentWithBranch(arg0, arg1, arg2, arg3 any) *gomock.Call

+ func (mr *MockGitRepoMockRecorder) GetProject(arg0, arg1 any) *gomock.Call

+ func (mr *MockGitRepoMockRecorder) ListCommits(arg0, arg1, arg2 any) *gomock.Call

+ type MockHelmerRepo struct

+ func NewMockHelmerRepo(ctrl *gomock.Controller) *MockHelmerRepo

+ func (m *MockHelmerRepo) EXPECT() *MockHelmerRepoMockRecorder

+ func (m *MockHelmerRepo) PackageChart(arg0, arg1 string) (string, error)

+ func (m *MockHelmerRepo) ReleaseStatus(arg0, arg1 string) types.Deploy

+ func (m *MockHelmerRepo) Rollback(arg0, arg1 string, arg2 bool, arg3 LogFn, arg4 bool) error

+ func (m *MockHelmerRepo) Uninstall(arg0, arg1 string, arg2 LogFn) error

+ func (m *MockHelmerRepo) UpgradeOrInstall(arg0 context.Context, arg1, arg2 string, arg3 *chart.Chart, ...) (*release.Release, error)

+ type MockHelmerRepoMockRecorder struct

+ func (mr *MockHelmerRepoMockRecorder) PackageChart(arg0, arg1 any) *gomock.Call

+ func (mr *MockHelmerRepoMockRecorder) ReleaseStatus(arg0, arg1 any) *gomock.Call

+ func (mr *MockHelmerRepoMockRecorder) Rollback(arg0, arg1, arg2, arg3, arg4 any) *gomock.Call

+ func (mr *MockHelmerRepoMockRecorder) Uninstall(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockHelmerRepoMockRecorder) UpgradeOrInstall(arg0, arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9 any) *gomock.Call

+ type MockK8sRepo struct

+ func NewMockK8sRepo(ctrl *gomock.Controller) *MockK8sRepo

+ func (m *MockK8sRepo) AddTlsSecret(arg0, arg1, arg2, arg3 string) (*v1.Secret, error)

+ func (m *MockK8sRepo) ClusterInfo() *ClusterInfo

+ func (m *MockK8sRepo) CopyFileToPod(arg0 context.Context, arg1 *CopyFileToPodInput) (*File, error)

+ func (m *MockK8sRepo) CopyFromPod(arg0 context.Context, arg1 *CopyFromPodInput) (*File, error)

+ func (m *MockK8sRepo) CreateDockerSecret(arg0 context.Context, arg1 string) (*v1.Secret, error)

+ func (m *MockK8sRepo) CreateNamespace(arg0 context.Context, arg1 string) (*v1.Namespace, error)

+ func (m *MockK8sRepo) DeleteNamespace(arg0 context.Context, arg1 string) error

+ func (m *MockK8sRepo) DeleteSecret(arg0 context.Context, arg1, arg2 string) error

+ func (m *MockK8sRepo) EXPECT() *MockK8sRepoMockRecorder

+ func (m *MockK8sRepo) Execute(arg0 context.Context, arg1 *Container, arg2 *ExecuteInput) error

+ func (m *MockK8sRepo) FindDefaultContainer(arg0 context.Context, arg1, arg2 string) (string, error)

+ func (m *MockK8sRepo) GetAllPodMetrics(arg0 context.Context, arg1 *Project) []v1beta1.PodMetrics

+ func (m *MockK8sRepo) GetCpuAndMemory(arg0 context.Context, arg1 []v1beta1.PodMetrics) (string, string)

+ func (m *MockK8sRepo) GetCpuAndMemoryInNamespace(arg0 context.Context, arg1 string) (string, string)

+ func (m *MockK8sRepo) GetCpuAndMemoryQuantity(arg0 v1beta1.PodMetrics) (*resource.Quantity, *resource.Quantity)

+ func (m *MockK8sRepo) GetNamespace(arg0 context.Context, arg1 string) (*v1.Namespace, error)

+ func (m *MockK8sRepo) GetPod(arg0, arg1 string) (*v1.Pod, error)

+ func (m *MockK8sRepo) GetPodLogs(arg0 context.Context, arg1, arg2 string, arg3 *v1.PodLogOptions) (string, error)

+ func (m *MockK8sRepo) GetPodMetrics(arg0 context.Context, arg1, arg2 string) (*v1beta1.PodMetrics, error)

+ func (m *MockK8sRepo) GetPodSelectorsByManifest(arg0 []string) []string

+ func (m *MockK8sRepo) IsPodRunning(arg0, arg1 string) (bool, string)

+ func (m *MockK8sRepo) ListEvents(arg0 string) ([]*v10.Event, error)

+ func (m *MockK8sRepo) LogStream(arg0 context.Context, arg1, arg2, arg3 string) (chan []byte, error)

+ func (m *MockK8sRepo) SplitManifests(arg0 string) []string

+ type MockK8sRepoMockRecorder struct

+ func (mr *MockK8sRepoMockRecorder) AddTlsSecret(arg0, arg1, arg2, arg3 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) ClusterInfo() *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) CopyFileToPod(arg0, arg1 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) CopyFromPod(arg0, arg1 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) CreateDockerSecret(arg0, arg1 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) CreateNamespace(arg0, arg1 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) DeleteNamespace(arg0, arg1 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) DeleteSecret(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) Execute(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) FindDefaultContainer(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) GetAllPodMetrics(arg0, arg1 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) GetCpuAndMemory(arg0, arg1 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) GetCpuAndMemoryInNamespace(arg0, arg1 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) GetCpuAndMemoryQuantity(arg0 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) GetNamespace(arg0, arg1 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) GetPod(arg0, arg1 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) GetPodLogs(arg0, arg1, arg2, arg3 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) GetPodMetrics(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) GetPodSelectorsByManifest(arg0 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) IsPodRunning(arg0, arg1 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) ListEvents(arg0 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) LogStream(arg0, arg1, arg2, arg3 any) *gomock.Call

+ func (mr *MockK8sRepoMockRecorder) SplitManifests(arg0 any) *gomock.Call

+ type MockNamespaceRepo struct

+ func NewMockNamespaceRepo(ctrl *gomock.Controller) *MockNamespaceRepo

+ func (m *MockNamespaceRepo) CanAccess(arg0 context.Context, arg1 int, arg2 *schematype.UserInfo) bool

+ func (m *MockNamespaceRepo) Create(arg0 context.Context, arg1 *CreateNamespaceInput) (*Namespace, error)

+ func (m *MockNamespaceRepo) Delete(arg0 context.Context, arg1 int) error

+ func (m *MockNamespaceRepo) EXPECT() *MockNamespaceRepoMockRecorder

+ func (m *MockNamespaceRepo) Favorite(arg0 context.Context, arg1 *FavoriteNamespaceInput) error

+ func (m *MockNamespaceRepo) FindByName(arg0 context.Context, arg1 string) (*Namespace, error)

+ func (m *MockNamespaceRepo) GetMarsNamespace(arg0 string) string

+ func (m *MockNamespaceRepo) IsOwner(arg0 context.Context, arg1 int, arg2 *schematype.UserInfo) (bool, error)

+ func (m *MockNamespaceRepo) List(arg0 context.Context, arg1 *ListNamespaceInput) ([]*Namespace, *pagination.Pagination, error)

+ func (m *MockNamespaceRepo) Show(arg0 context.Context, arg1 int) (*Namespace, error)

+ func (m *MockNamespaceRepo) SyncMembers(arg0 context.Context, arg1 int, arg2 []string) (*Namespace, error)

+ func (m *MockNamespaceRepo) Transfer(arg0 context.Context, arg1 int, arg2 string) (*Namespace, error)

+ func (m *MockNamespaceRepo) Update(arg0 context.Context, arg1 *UpdateNamespaceInput) (*Namespace, error)

+ func (m *MockNamespaceRepo) UpdatePrivate(arg0 context.Context, arg1 int, arg2 bool) (*Namespace, error)

+ type MockNamespaceRepoMockRecorder struct

+ func (mr *MockNamespaceRepoMockRecorder) CanAccess(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockNamespaceRepoMockRecorder) Create(arg0, arg1 any) *gomock.Call

+ func (mr *MockNamespaceRepoMockRecorder) Delete(arg0, arg1 any) *gomock.Call

+ func (mr *MockNamespaceRepoMockRecorder) Favorite(arg0, arg1 any) *gomock.Call

+ func (mr *MockNamespaceRepoMockRecorder) FindByName(arg0, arg1 any) *gomock.Call

+ func (mr *MockNamespaceRepoMockRecorder) GetMarsNamespace(arg0 any) *gomock.Call

+ func (mr *MockNamespaceRepoMockRecorder) IsOwner(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockNamespaceRepoMockRecorder) List(arg0, arg1 any) *gomock.Call

+ func (mr *MockNamespaceRepoMockRecorder) Show(arg0, arg1 any) *gomock.Call

+ func (mr *MockNamespaceRepoMockRecorder) SyncMembers(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockNamespaceRepoMockRecorder) Transfer(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockNamespaceRepoMockRecorder) Update(arg0, arg1 any) *gomock.Call

+ func (mr *MockNamespaceRepoMockRecorder) UpdatePrivate(arg0, arg1, arg2 any) *gomock.Call

+ type MockPictureRepo struct

+ func NewMockPictureRepo(ctrl *gomock.Controller) *MockPictureRepo

+ func (m *MockPictureRepo) EXPECT() *MockPictureRepoMockRecorder

+ func (m *MockPictureRepo) Get(arg0 context.Context, arg1 bool) (*application.PictureItem, error)

+ type MockPictureRepoMockRecorder struct

+ func (mr *MockPictureRepoMockRecorder) Get(arg0, arg1 any) *gomock.Call

+ type MockProjectRepo struct

+ func NewMockProjectRepo(ctrl *gomock.Controller) *MockProjectRepo

+ func (m *MockProjectRepo) Create(arg0 context.Context, arg1 *CreateProjectInput) (*Project, error)

+ func (m *MockProjectRepo) Delete(arg0 context.Context, arg1 int) error

+ func (m *MockProjectRepo) EXPECT() *MockProjectRepoMockRecorder

+ func (m *MockProjectRepo) FindByName(arg0 context.Context, arg1 string, arg2 int) (*Project, error)

+ func (m *MockProjectRepo) FindByVersion(arg0 context.Context, arg1, arg2 int) (*Project, error)

+ func (m *MockProjectRepo) GetAllActiveContainers(arg0 context.Context, arg1 int) ([]*types.StateContainer, error)

+ func (m *MockProjectRepo) GetPreOccupiedLenByValuesYaml(arg0 string) int

+ func (m *MockProjectRepo) GetProjectEndpointsInNamespace(arg0 context.Context, arg1 string, arg2 ...int) ([]*types.ServiceEndpoint, error)

+ func (m *MockProjectRepo) List(arg0 context.Context, arg1 *ListProjectInput) ([]*Project, *pagination.Pagination, error)

+ func (m *MockProjectRepo) Show(arg0 context.Context, arg1 int) (*Project, error)

+ func (m *MockProjectRepo) UpdateDeployStatus(arg0 context.Context, arg1 int, arg2 types.Deploy) (*Project, error)

+ func (m *MockProjectRepo) UpdateProject(arg0 context.Context, arg1 *UpdateProjectInput) (*Project, error)

+ func (m *MockProjectRepo) UpdateStatusByVersion(arg0 context.Context, arg1 int, arg2 types.Deploy, arg3 int) (*Project, error)

+ func (m *MockProjectRepo) UpdateVersion(arg0 context.Context, arg1, arg2 int) (*Project, error)

+ type MockProjectRepoMockRecorder struct

+ func (mr *MockProjectRepoMockRecorder) Create(arg0, arg1 any) *gomock.Call

+ func (mr *MockProjectRepoMockRecorder) Delete(arg0, arg1 any) *gomock.Call

+ func (mr *MockProjectRepoMockRecorder) FindByName(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockProjectRepoMockRecorder) FindByVersion(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockProjectRepoMockRecorder) GetAllActiveContainers(arg0, arg1 any) *gomock.Call

+ func (mr *MockProjectRepoMockRecorder) GetPreOccupiedLenByValuesYaml(arg0 any) *gomock.Call

+ func (mr *MockProjectRepoMockRecorder) GetProjectEndpointsInNamespace(arg0, arg1 any, arg2 ...any) *gomock.Call

+ func (mr *MockProjectRepoMockRecorder) List(arg0, arg1 any) *gomock.Call

+ func (mr *MockProjectRepoMockRecorder) Show(arg0, arg1 any) *gomock.Call

+ func (mr *MockProjectRepoMockRecorder) UpdateDeployStatus(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockProjectRepoMockRecorder) UpdateProject(arg0, arg1 any) *gomock.Call

+ func (mr *MockProjectRepoMockRecorder) UpdateStatusByVersion(arg0, arg1, arg2, arg3 any) *gomock.Call

+ func (mr *MockProjectRepoMockRecorder) UpdateVersion(arg0, arg1, arg2 any) *gomock.Call

+ type MockRecorder struct

+ func NewMockRecorder(ctrl *gomock.Controller) *MockRecorder

+ func (m *MockRecorder) Close() error

+ func (m *MockRecorder) Container() *Container

+ func (m *MockRecorder) Duration() time.Duration

+ func (m *MockRecorder) EXPECT() *MockRecorderMockRecorder

+ func (m *MockRecorder) File() *File

+ func (m *MockRecorder) GetShell() string

+ func (m *MockRecorder) Resize(arg0, arg1 uint16)

+ func (m *MockRecorder) SetShell(arg0 string)

+ func (m *MockRecorder) User() *schematype.UserInfo

+ func (m *MockRecorder) Write(arg0 []byte) (int, error)

+ type MockRecorderMockRecorder struct

+ func (mr *MockRecorderMockRecorder) Close() *gomock.Call

+ func (mr *MockRecorderMockRecorder) Container() *gomock.Call

+ func (mr *MockRecorderMockRecorder) Duration() *gomock.Call

+ func (mr *MockRecorderMockRecorder) File() *gomock.Call

+ func (mr *MockRecorderMockRecorder) GetShell() *gomock.Call

+ func (mr *MockRecorderMockRecorder) Resize(arg0, arg1 any) *gomock.Call

+ func (mr *MockRecorderMockRecorder) SetShell(arg0 any) *gomock.Call

+ func (mr *MockRecorderMockRecorder) User() *gomock.Call

+ func (mr *MockRecorderMockRecorder) Write(arg0 any) *gomock.Call

+ type MockRepoRepo struct

+ func NewMockRepoRepo(ctrl *gomock.Controller) *MockRepoRepo

+ func (m *MockRepoRepo) All(arg0 context.Context, arg1 *AllRepoRequest) ([]*Repo, error)

+ func (m *MockRepoRepo) Clone(arg0 context.Context, arg1 *CloneRepoInput) (*Repo, error)

+ func (m *MockRepoRepo) Create(arg0 context.Context, arg1 *CreateRepoInput) (*Repo, error)

+ func (m *MockRepoRepo) Delete(arg0 context.Context, arg1 int) error

+ func (m *MockRepoRepo) EXPECT() *MockRepoRepoMockRecorder

+ func (m *MockRepoRepo) List(arg0 context.Context, arg1 *ListRepoRequest) ([]*Repo, *pagination.Pagination, error)

+ func (m *MockRepoRepo) Show(arg0 context.Context, arg1 int) (*Repo, error)

+ func (m *MockRepoRepo) ToggleEnabled(arg0 context.Context, arg1 int, arg2 bool) (*Repo, error)

+ func (m *MockRepoRepo) Update(arg0 context.Context, arg1 *UpdateRepoInput) (*Repo, error)

+ type MockRepoRepoMockRecorder struct

+ func (mr *MockRepoRepoMockRecorder) All(arg0, arg1 any) *gomock.Call

+ func (mr *MockRepoRepoMockRecorder) Clone(arg0, arg1 any) *gomock.Call

+ func (mr *MockRepoRepoMockRecorder) Create(arg0, arg1 any) *gomock.Call

+ func (mr *MockRepoRepoMockRecorder) Delete(arg0, arg1 any) *gomock.Call

+ func (mr *MockRepoRepoMockRecorder) List(arg0, arg1 any) *gomock.Call

+ func (mr *MockRepoRepoMockRecorder) Show(arg0, arg1 any) *gomock.Call

+ func (mr *MockRepoRepoMockRecorder) ToggleEnabled(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockRepoRepoMockRecorder) Update(arg0, arg1 any) *gomock.Call

+ type Namespace struct

+ CreatedAt time.Time

+ CreatorEmail string

+ DeletedAt *time.Time

+ Description string

+ Favorites []*Favorite

+ ID int

+ ImagePullSecrets []string

+ Members []*Member

+ Name string

+ Private bool

+ Projects []*Project

+ UpdatedAt time.Time

+ func ToNamespace(namespace *ent.Namespace) *Namespace

+ func (ns *Namespace) GetImagePullSecrets() []*types.ImagePullSecret

+ type NamespaceCreatedData struct

+ NsK8sObj *corev1.Namespace

+ NsModel *Namespace

+ type NamespaceDeletedData struct

+ ID int

+ type NamespaceRepo interface

+ CanAccess func(ctx context.Context, namespaceID int, user *auth.UserInfo) bool

+ Create func(ctx context.Context, input *CreateNamespaceInput) (*Namespace, error)

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

+ Favorite func(ctx context.Context, input *FavoriteNamespaceInput) error

+ FindByName func(ctx context.Context, name string) (*Namespace, error)

+ GetMarsNamespace func(name string) string

+ IsOwner func(ctx context.Context, namespaceID int, user *auth.UserInfo) (bool, error)

+ List func(ctx context.Context, input *ListNamespaceInput) ([]*Namespace, *pagination.Pagination, error)

+ Show func(ctx context.Context, id int) (*Namespace, error)

+ SyncMembers func(ctx context.Context, namespaceID int, memberEmails []string) (*Namespace, error)

+ Transfer func(ctx context.Context, id int, email string) (*Namespace, error)

+ Update func(ctx context.Context, input *UpdateNamespaceInput) (*Namespace, error)

+ UpdatePrivate func(ctx context.Context, namespaceID int, private bool) (*Namespace, error)

+ func NewNamespaceRepo(logger mlog.Logger, data data.Data) NamespaceRepo

+ type PictureRepo interface

+ Get func(ctx context.Context, random bool) (*application.PictureItem, error)

+ func NewPictureRepo(logger mlog.Logger, pl application.PluginManger) PictureRepo

+ type Pipeline struct

+ Status application.Status

+ WebURL string

+ type Project struct

+ Atomic bool

+ Config string

+ ConfigType string

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ DeployStatus types.Deploy

+ DockerImage []string

+ Elements []*types.KeyValue

+ EnvValues []*types.KeyValue

+ ExtraValues []*websocket_pb.ExtraValue

+ FinalExtraValues []*websocket_pb.ExtraValue

+ GitBranch string

+ GitCommit string

+ GitCommitAuthor string

+ GitCommitDate *time.Time

+ GitCommitTitle string

+ GitCommitWebURL string

+ GitProjectID int

+ ID int

+ Manifest []string

+ Name string

+ Namespace *Namespace

+ NamespaceID int

+ OverrideValues string

+ PodSelectors []string

+ Repo *Repo

+ RepoID int

+ UpdatedAt time.Time

+ Version int

+ func ToProject(project *ent.Project) *Project

+ type ProjectChangedData struct

+ ID int

+ Username string

+ type ProjectDeletedPayload struct

+ NamespaceID int

+ ProjectID int

+ type ProjectRepo interface

+ Create func(ctx context.Context, project *CreateProjectInput) (*Project, error)

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

+ FindByName func(ctx context.Context, name string, nsID int) (*Project, error)

+ FindByVersion func(ctx context.Context, id, version int) (*Project, error)

+ GetAllActiveContainers func(ctx context.Context, id int) ([]*types.StateContainer, error)

+ GetPreOccupiedLenByValuesYaml func(values string) int

+ GetProjectEndpointsInNamespace func(ctx context.Context, namespace string, projectIDs ...int) ([]*types.ServiceEndpoint, error)

+ List func(ctx context.Context, input *ListProjectInput) ([]*Project, *pagination.Pagination, error)

+ Show func(ctx context.Context, id int) (*Project, error)

+ UpdateDeployStatus func(ctx context.Context, id int, status types.Deploy) (*Project, error)

+ UpdateProject func(ctx context.Context, input *UpdateProjectInput) (*Project, error)

+ UpdateStatusByVersion func(ctx context.Context, id int, status types.Deploy, version int) (*Project, error)

+ UpdateVersion func(ctx context.Context, id int, version int) (*Project, error)

+ func NewProjectRepo(logger mlog.Logger, data data.Data) ProjectRepo

+ type Recorder interface

+ Close func() error

+ Container func() *Container

+ Duration func() time.Duration

+ File func() *File

+ GetShell func() string

+ Resize func(cols, rows uint16)

+ SetShell func(string)

+ User func() *auth.UserInfo

+ Write func(p []byte) (n int, err error)

+ type ReleaseList map[string]ListReleaseItem

+ func (l ReleaseList) Add(r *release.Release)

+ func (l ReleaseList) GetStatus(namespace, name string) string

+ type Repo struct

+ CreatedAt time.Time

+ DefaultBranch string

+ DeletedAt *time.Time

+ Description string

+ Enabled bool

+ GitProjectID int32

+ GitProjectName string

+ ID int

+ MarsConfig *mars.Config

+ Name string

+ NeedGitRepo bool

+ Projects []*Project

+ UpdatedAt time.Time

+ func ToRepo(data *ent.Repo) *Repo

+ func (r *Repo) GetMarsConfig() (cfg *mars.Config)

+ type RepoRepo interface

+ All func(ctx context.Context, in *AllRepoRequest) ([]*Repo, error)

+ Clone func(ctx context.Context, input *CloneRepoInput) (*Repo, error)

+ Create func(ctx context.Context, in *CreateRepoInput) (*Repo, error)

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

+ List func(ctx context.Context, in *ListRepoRequest) ([]*Repo, *pagination.Pagination, error)

+ Show func(ctx context.Context, id int) (*Repo, error)

+ ToggleEnabled func(ctx context.Context, id int, enabled bool) (*Repo, error)

+ Update func(ctx context.Context, in *UpdateRepoInput) (*Repo, error)

+ func NewRepo(logger mlog.Logger, data data.Data, gitRepo GitRepo) RepoRepo

+ type RuntimeObjectList []runtime.Object

+ func FilterRuntimeObjectFromManifests[T runtime.Object](logger mlog.Logger, manifests []string) RuntimeObjectList

+ func (l RuntimeObjectList) Has(in runtime.Object) bool

+ type SortStatePod []StatePod

+ func (s SortStatePod) Len() int

+ func (s SortStatePod) Less(i, j int) bool

+ func (s SortStatePod) Swap(i, j int)

+ type StatePod struct

+ IsOld bool

+ OrderIndex int

+ Pending bool

+ Pod *corev1.Pod

+ Terminating bool

+ type StreamUploadFileRequest struct

+ Container string

+ FileData chan []byte

+ FileName string

+ Namespace string

+ Pod string

+ Username string

+ type StringYamlPrettier struct

+ Str string

+ func (s *StringYamlPrettier) PrettyYaml() string

+ type UpdateFileRequest struct

+ Container string

+ ContainerPath string

+ ID int

+ Namespace string

+ Pod string

+ type UpdateNamespaceInput struct

+ Description string

+ ID int

+ type UpdateProjectInput struct

+ Atomic *bool

+ Config string

+ ConfigType string

+ DockerImage []string

+ EnvValues []*types.KeyValue

+ ExtraValues []*websocket_pb.ExtraValue

+ FinalExtraValues []*websocket_pb.ExtraValue

+ GitBranch string

+ GitCommit string

+ GitCommitAuthor string

+ GitCommitDate *time.Time

+ GitCommitTitle string

+ GitCommitWebURL string

+ ID int

+ Manifest []string

+ OverrideValues string

+ PodSelectors []string

+ type UpdateRepoInput struct

+ Description string

+ GitProjectID *int32

+ ID int32

+ MarsConfig *mars.Config

+ Name string

+ NeedGitRepo bool

+ type WrapLogFn func(container []*websocket_pb.Container, format string, v ...any)

+ func (l WrapLogFn) UnWrap() func(format string, v ...any)

+ type YamlPrettier interface

+ PrettyYaml func() string

v5.0.0-beta.26

Sep 11, 2024

v5.0.0-beta.24

Sep 11, 2024

v5.0.0-beta.23

Sep 11, 2024

v5.0.0-beta.22

Sep 11, 2024

v5.0.0-beta.21

Sep 11, 2024

v5.0.0-beta.20

Sep 11, 2024

v5.0.0-beta.19

Sep 10, 2024

v5.0.0-beta.18

Sep 10, 2024

v5.0.0-beta.17

Sep 10, 2024

v5.0.0-beta.16

Sep 10, 2024

v5.0.0-beta.15

Sep 9, 2024

v5.0.0-beta.14

Sep 5, 2024

v5.0.0-beta.13

Sep 5, 2024

v5.0.0-beta.12

Sep 4, 2024

v5.0.0-beta.11

Sep 4, 2024

v5.0.0-beta.10

Sep 4, 2024

v5.0.0-beta.9

Sep 4, 2024

v5.0.0-beta.8

Sep 4, 2024

v5.0.0-beta.7

Sep 4, 2024

v5.0.0-beta.4

Sep 4, 2024

v5.0.0-beta.3

Sep 4, 2024

v5.0.0-beta.2

Sep 3, 2024

v5.0.0-beta.1

Sep 3, 2024

v5.0.0-beta

Sep 2, 2024

v5.0.0-alpha

Sep 2, 2024

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