repo

package
v5.0.10 Latest Latest
Warning

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

 Go to latest Published: Oct 10, 2024 License: AGPL-3.0 Imports: 102 Imported by: 0

Documentation

Overview

Package repo is a generated GoMock package.

Index

Constants

View Source 
const (
	AuditLogEvent         event.Event = "audit_log"
	EventNamespaceCreated event.Event = "namespace_created"
	EventNamespaceDeleted event.Event = "namespace_deleted"
	EventProjectChanged   event.Event = "project_changed"
	EventProjectDeleted   event.Event = "project_deleted"
)
View Source 
const (
	StatusUnknown  string = "unknown"
	StatusPending  string = "pending"
	StatusDeployed string = "deployed"
	StatusFailed   string = "failed"
)
View Source 
const RevisionAnnotation = "deployment.kubernetes.io/revision"
View Source 
const StreamUploadFileDisk = "grpc_upload"

Variables

View Source 
var DirSizeCacheSeconds = int((15 * time.Minute).Seconds())
View Source 
var WireRepoSet = wire.NewSet(
	NewCronRepo,
	NewAuthRepo,
	NewK8sRepo,
	NewDefaultHelmer,
	NewRepo,
	NewDefaultArchiver,
	NewExecutorManager,
	NewFileRepo,
	NewEndpointRepo,
	timer.NewReal,
	NewNamespaceRepo,
	NewEventRepo,
	NewPictureRepo,
	NewProjectRepo,
	NewGitRepo,
	NewChangelogRepo,
	NewAccessTokenRepo,
)

Functions

func IsRemoteLocalChartPath 

func IsRemoteLocalChartPath(input string) bool

func ToError 

func ToError(code uint32, err any) error

Types

type AccessToken 

type AccessToken struct {
	ID         int
	CreatedAt  time.Time
	UpdatedAt  time.Time
	DeletedAt  *time.Time
	Token      string
	Usage      string
	Email      string
	ExpiredAt  time.Time
	LastUsedAt *time.Time
	UserInfo   schematype.UserInfo
}

func ToAccessToken 

func ToAccessToken(token *ent.AccessToken) *AccessToken

func (*AccessToken) Expired 

func (at *AccessToken) Expired() bool

type AccessTokenRepo 

type AccessTokenRepo interface {
	List(ctx context.Context, input *ListAccessTokenInput) ([]*AccessToken, *pagination.Pagination, error)
	Grant(ctx context.Context, input *GrantAccessTokenInput) (*AccessToken, error)
	Lease(ctx context.Context, token string, expireSeconds int32) (*AccessToken, error)
	Revoke(ctx context.Context, token string) error
}

func NewAccessTokenRepo 

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

type AllRepoRequest 

type AllRepoRequest struct {
	NeedGitRepo   *bool
	Enabled       *bool
	OrderByIDDesc *bool
}

type AnyYamlPrettier 

type AnyYamlPrettier map[string]any

func (AnyYamlPrettier) PrettyYaml 

func (s AnyYamlPrettier) PrettyYaml() string

type Archiver 

type Archiver interface {
	Archive(sources []string, destination string) error
	Open(path string) (io.ReadCloser, error)
	Remove(path string) error
}

func NewDefaultArchiver 

func NewDefaultArchiver() Archiver

type AuditLog 

type AuditLog interface {
	// GetUsername 获取用户
	GetUsername() string
	// GetAction 行为
	GetAction() types.EventActionType
	// GetMsg desc
	GetMsg() string
	// GetOldStr old config str
	GetOldStr() string
	// GetNewStr new config str
	GetNewStr() string
	// GetFileID file id
	GetFileID() int
	// GetDuration duration
	GetDuration() string
}

func NewEventAuditLog 

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

type AuditOption 

type AuditOption func(*auditLogImpl)

func AuditWithDuration 

func AuditWithDuration(d string) AuditOption

func AuditWithFileID 

func AuditWithFileID(id int) AuditOption

func AuditWithOldNew 

func AuditWithOldNew(o, n YamlPrettier) AuditOption

func AuditWithOldNewStr 

func AuditWithOldNewStr(o, n string) AuditOption

type AuthRepo 

type AuthRepo interface {
	Login(ctx context.Context, input *LoginInput) (*LoginResponse, error)
	VerifyToken(ctx context.Context, token string) (*auth2.UserInfo, error)
	Settings(ctx context.Context) (data.OidcConfig, error)
	Sign(ctx context.Context, input *auth2.UserInfo) (*LoginResponse, error)
}

func NewAuthRepo 

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

type Branch 

type Branch struct {
	Name      string `json:"name"`
	IsDefault bool   `json:"is_default"`
	WebURL    string `json:"web_url"`
}

type Changelog 

type Changelog struct {
	ID               int
	CreatedAt        time.Time
	UpdatedAt        time.Time
	DeletedAt        *time.Time
	Version          int
	Username         string
	Config           string
	GitBranch        string
	GitCommit        string
	DockerImage      []string
	EnvValues        []*types.KeyValue
	ExtraValues      []*websocket_pb.ExtraValue
	FinalExtraValues []*websocket_pb.ExtraValue
	GitCommitWebURL  string
	GitCommitTitle   string
	GitCommitAuthor  string
	GitCommitDate    *time.Time
	ConfigChanged    bool
	ProjectID        int

	Project *Project
}

func ToChangeLog 

func ToChangeLog(c *ent.Changelog) *Changelog

type ChangelogRepo 

type ChangelogRepo interface {
	FindLastChangelogsByProjectID(ctx context.Context, input *FindLastChangelogsByProjectIDChangeLogInput) ([]*Changelog, error)
	Create(ctx context.Context, input *CreateChangeLogInput) (*Changelog, error)
	FindLastChangeByProjectID(ctx context.Context, projectID int) (*Changelog, error)
}

func NewChangelogRepo 

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

type CloneRepoInput 

type CloneRepoInput struct {
	ID   int
	Name string
}

type ClusterInfo 

type ClusterInfo struct {
	// 健康状况
	Status ClusterStatus `json:"status"`

	// 可用内存
	FreeMemory string `json:"free_memory"`
	// 可用 cpu
	FreeCpu string `json:"free_cpu"`

	// 可分配内存
	FreeRequestMemory string `json:"free_request_memory"`
	// 可分配 cpu
	FreeRequestCpu string `json:"free_request_cpu"`

	// 总共的可调度的内存
	TotalMemory string `json:"total_memory"`
	// 总共的可调度的 cpu
	TotalCpu string `json:"total_cpu"`

	// 内存使用率
	UsageMemoryRate string `json:"usage_memory_rate"`
	// cpu 使用率
	UsageCpuRate string `json:"usage_cpu_rate"`

	// 内存分配率
	RequestMemoryRate string `json:"request_memory_rate"`
	// cpu 分配率
	RequestCpuRate string `json:"request_cpu_rate"`
}

type ClusterStatus 

type ClusterStatus = string
const (
	StatusBad     ClusterStatus = "bad"
	StatusNotGood ClusterStatus = "not good"
	StatusHealth  ClusterStatus = "health"
)

type Commit 

type Commit struct {
	ID             string
	ShortID        string
	AuthorName     string
	AuthorEmail    string
	CommitterName  string
	CommitterEmail string
	Message        string
	Title          string
	WebURL         string
	CreatedAt      *time.Time
	CommittedDate  *time.Time
}

func ToCommit 

func ToCommit(v application.Commit) *Commit

type Container 

type Container struct {
	Namespace string `json:"namespace"`
	Pod       string `json:"pod"`
	Container string `json:"container"`
}

type CopyFileToPodInput 

type CopyFileToPodInput struct {
	FileId    int64
	Namespace string
	Pod       string
	Container string
}

type CopyFromPodInput 

type CopyFromPodInput struct {
	Namespace string
	Pod       string
	Container string
	// pod 内的绝对路径
	FilePath string
	UserName string
}

type CreateChangeLogInput 

type CreateChangeLogInput struct {
	Version          int
	Username         string
	Config           string
	GitBranch        string
	GitCommit        string
	DockerImage      []string
	EnvValues        []*types.KeyValue
	ExtraValues      []*websocket_pb.ExtraValue
	FinalExtraValues []*websocket_pb.ExtraValue
	GitCommitWebURL  string
	GitCommitTitle   string
	GitCommitAuthor  string
	GitCommitDate    *time.Time
	ProjectID        int
	ConfigChanged    bool
}

type CreateFileInput 

type CreateFileInput struct {
	Path       string
	Username   string
	Size       uint64
	UploadType schematype.UploadType

	Namespace string
	Pod       string
	Container string
}

type CreateNamespaceInput 

type CreateNamespaceInput struct {
	Name             string
	ImagePullSecrets []string
	Description      string
	CreatorEmail     string
}

type CreateProjectInput 

type CreateProjectInput struct {
	Name         string
	GitProjectID int
	GitBranch    string
	GitCommit    string
	Config       string
	Atomic       *bool
	ConfigType   string
	NamespaceID  int
	PodSelectors []string
	DeployStatus types.Deploy
	RepoID       int
	Creator      string
}

type CreateRepoInput 

type CreateRepoInput struct {
	Name         string
	Enabled      bool
	NeedGitRepo  bool
	GitProjectID *int32
	MarsConfig   *mars.Config
	Description  string
}

type CronRepo 

type CronRepo interface {
	CleanUploadFiles() error
	FixDeployStatus() error
	DiskInfo() (int64, error)
	CacheAllBranches() error
	SyncImagePullSecrets() error
}

func NewCronRepo 

func NewCronRepo(
	timer timer.Timer,
	logger mlog.Logger,
	fileRepo FileRepo,
	cache cache.Cache,
	repoRepo RepoRepo,
	nsRepo NamespaceRepo,
	k8sRepo K8sRepo,
	pluginMgr application.PluginManger,
	event EventRepo,
	data data.Data,
	up uploader.Uploader,
	helm HelmerRepo,
	gitRepo GitRepo,
	cronManager cron.Manager,
) CronRepo

type DefaultHelmer 

type DefaultHelmer struct {
	Debug      bool
	DockerAuth config.DockerAuths
	KubeConfig string
	// contains filtered or unexported fields
}

func (*DefaultHelmer) PackageChart 

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

func (*DefaultHelmer) ReleaseStatus 

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

func (*DefaultHelmer) Rollback 

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

func (*DefaultHelmer) Uninstall 

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

func (*DefaultHelmer) UpgradeOrInstall 

func (d *DefaultHelmer) UpgradeOrInstall(ctx context.Context, releaseName, namespace string, ch *chart.Chart, valueOpts *values.Options, fn WrapLogFn, wait bool, timeoutSeconds int64, dryRun bool, desc string) (*release.Release, error)

type DockerConfig 

type DockerConfig map[string]DockerConfigEntry

type DockerConfigEntry 

type DockerConfigEntry struct {
	Username string `json:"username,omitempty"`
	Password string `json:"password,omitempty"`
	Email    string `json:"email,omitempty"`
	Auth     string `json:"auth,omitempty"`
}

type DockerConfigJSON 

type DockerConfigJSON struct {
	Auths       DockerConfig      `json:"auths"`
	HttpHeaders map[string]string `json:"HttpHeaders,omitempty"`
}

type EndpointMapping 

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

func (EndpointMapping) AllEndpoints 

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

func (EndpointMapping) Get 

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

func (EndpointMapping) Sort 

func (e EndpointMapping) Sort()

type EndpointRepo 

type EndpointRepo interface {
	InNamespace(ctx context.Context, namespaceID int) (res []*types.ServiceEndpoint, err error)
	InProject(ctx context.Context, projectID int) (res []*types.ServiceEndpoint, err error)
}

func NewEndpointRepo 

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

type Event 

type Event struct {
	ID        int
	CreatedAt time.Time
	UpdatedAt time.Time
	DeletedAt *time.Time
	Action    types.EventActionType
	Username  string
	Message   string
	Old       string
	New       string
	Duration  string
	FileID    *int
	HasDiff   bool

	File *File
}

func ToEvent 

func ToEvent(data *ent.Event) *Event

type EventRepo 

type EventRepo interface {
	List(ctx context.Context, input *ListEventInput) (events []*Event, pag *pagination.Pagination, err error)
	Show(ctx context.Context, id int) (*Event, error)
	Dispatch(created event.Event, createdData any)

	// AuditLogWithChange 记录审计日志
	AuditLogWithChange(action types.EventActionType, username string, msg string, oldS, newS YamlPrettier)

	// AuditLog 记录审计日志
	AuditLog(action types.EventActionType, username string, msg string)

	// AuditLogWithRequest grpc审计日志
	AuditLogWithRequest(action types.EventActionType, username string, msg string, req any)

	// FileAuditLog 记录文件审计日志
	FileAuditLog(action types.EventActionType, username string, msg string, fileId int)

	// FileAuditLogWithDuration 记录文件审计日志
	FileAuditLogWithDuration(action types.EventActionType, username string, msg string, fileId int, duration time.Duration)

	HandleAuditLog(data any, e event.Event) error
}

func NewEventRepo 

func NewEventRepo(projectRepo ProjectRepo, k8sRepo K8sRepo, pl application.PluginManger, clRepo ChangelogRepo, logger mlog.Logger, data data.Data, eventer event.Dispatcher) EventRepo

type ExecuteInput 

type ExecuteInput struct {
	Stdin             io.Reader
	Stdout, Stderr    io.Writer
	TTY               bool
	Cmd               []string
	TerminalSizeQueue remotecommand.TerminalSizeQueue
}

type Executor 

type Executor interface {
	WithMethod(method string) Executor
	WithContainer(namespace, pod, container string) Executor
	WithCommand(cmd []string) Executor
	Execute(context.Context, *ExecuteInput) error
}

type ExecutorManager 

type ExecutorManager interface {
	New() Executor
	NewFileCopy(maxTries int, errOut io.Writer) k8s.FileCopy
}

func NewExecutorManager 

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

type Favorite 

type Favorite struct {
	ID          int
	NamespaceID int
	Email       string
}

func ToFavorite 

func ToFavorite(v *ent.Favorite) *Favorite

type FavoriteNamespaceInput 

type FavoriteNamespaceInput struct {
	NamespaceID int
	UserEmail   string
	Favorite    bool
}

type File 

type File struct {
	ID            int
	CreatedAt     time.Time
	UpdatedAt     time.Time
	DeletedAt     *time.Time
	UploadType    schematype.UploadType
	Path          string
	Size          uint64
	Username      string
	Namespace     string
	Pod           string
	Container     string
	ContainerPath string

	HumanizeSize string
}

func ToFile 

func ToFile(file *ent.File) *File

type FileRepo 

type FileRepo interface {
	MaxUploadSize() uint64
	Delete(ctx context.Context, id int) error
	ShowRecords(ctx context.Context, id int) (io.ReadCloser, error)
	DiskInfo(force bool) (int64, error)
	List(ctx context.Context, input *ListFileInput) ([]*File, *pagination.Pagination, error)
	GetByID(ctx context.Context, id int) (*File, error)
	Create(todo context.Context, input *CreateFileInput) (*File, error)
	NewDisk(disk string) uploader.Uploader
	NewFile(fpath string) (uploader.File, error)
	NewRecorder(user *auth.UserInfo, container *Container) Recorder
	Update(ctx context.Context, i *UpdateFileRequest) (*File, error)
	StreamUploadFile(ctx context.Context, input *StreamUploadFileRequest) (*File, error)
}

func NewFileRepo 

func NewFileRepo(
	logger mlog.Logger,
	data data.Data,
	cache cache.Cache,
	uploader uploader.Uploader,
	timer timer.Timer,
) FileRepo

type FindLastChangelogsByProjectIDChangeLogInput 

type FindLastChangelogsByProjectIDChangeLogInput struct {
	OnlyChanged        bool
	ProjectID          int
	OrderByVersionDesc *bool
	Limit              int
}

type GitProject 

type GitProject struct {
	ID            int64  `json:"id"`
	Name          string `json:"name"`
	DefaultBranch string `json:"default_branch"`
	WebURL        string `json:"web_url"`
	Path          string `json:"path"`
	AvatarURL     string `json:"avatar_url"`
	Description   string `json:"description"`
}

func ToGitProject 

func ToGitProject(gp application.Project) *GitProject

type GitRepo 

type GitRepo interface {
	AllProjects(ctx context.Context, forceFresh bool) (projects []*GitProject, err error)
	AllBranches(ctx context.Context, projectID int, forceFresh bool) (branches []*Branch, err error)
	ListCommits(ctx context.Context, projectID int, branch string) ([]*Commit, error)
	GetCommit(ctx context.Context, projectID int, sha string) (*Commit, error)
	GetCommitPipeline(ctx context.Context, projectID int, branch, sha string) (*Pipeline, error)
	GetByProjectID(ctx context.Context, id int) (project *GitProject, err error)
	GetFileContentWithBranch(ctx context.Context, projectID int, branch, path string) (string, error)
	GetProject(ctx context.Context, id int) (project *GitProject, err error)
	GetChartValuesYaml(ctx context.Context, localChartPath string) (string, error)
}

func NewGitRepo 

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

type GrantAccessTokenInput 

type GrantAccessTokenInput struct {
	ExpireSeconds int32
	Usage         string
	User          *auth.UserInfo
}

type HelmerRepo 

type HelmerRepo interface {
	UpgradeOrInstall(ctx context.Context, releaseName, namespace string, ch *chart.Chart, valueOpts *values.Options, fn WrapLogFn, wait bool, timeoutSeconds int64, dryRun bool, desc string) (*release.Release, error)
	Rollback(releaseName, namespace string, wait bool, log LogFn, dryRun bool) error
	Uninstall(releaseName, namespace string, log LogFn) error
	ReleaseStatus(releaseName, namespace string) types.Deploy
	PackageChart(path string, destDir string) (string, error)
}

func NewDefaultHelmer 

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

type K8sRepo 

type K8sRepo interface {
	SplitManifests(manifest string) []string
	AddTlsSecret(ns string, name string, key string, crt string) (*corev1.Secret, error)
	GetPodMetrics(ctx context.Context, namespace, podName string) (*v1beta1.PodMetrics, error)
	CreateDockerSecret(ctx context.Context, namespace string) (*corev1.Secret, error)
	GetNamespace(ctx context.Context, name string) (*corev1.Namespace, error)
	CreateNamespace(ctx context.Context, name string) (*corev1.Namespace, error)
	LogStream(ctx context.Context, namespace, pod, container string) (chan []byte, error)
	GetPodLogs(ctx context.Context, namespace, podName string, options *corev1.PodLogOptions) (string, error)
	FindDefaultContainer(ctx context.Context, namespace string, pod string) (string, error)
	GetPod(namespace, podName string) (*corev1.Pod, error)
	ListEvents(namespace string) ([]*eventv1.Event, error)
	IsPodRunning(namespace, podName string) (running bool, notRunningReason string)
	GetPodSelectorsByManifest(manifests []string) []string
	GetCpuAndMemoryInNamespace(ctx context.Context, namespace string) (string, string)
	GetCpuAndMemory(ctx context.Context, list []v1beta1.PodMetrics) (string, string)
	GetCpuAndMemoryQuantity(pod v1beta1.PodMetrics) (cpu *resource.Quantity, memory *resource.Quantity)
	ClusterInfo() *ClusterInfo

	Execute(ctx context.Context, c *Container, input *ExecuteInput) error
	DeleteSecret(ctx context.Context, namespace, secret string) error
	DeleteNamespace(ctx context.Context, name string) error

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

	CopyFileToPod(ctx context.Context, input *CopyFileToPodInput) (*File, error)
	CopyFromPod(ctx context.Context, input *CopyFromPodInput) (*File, error)
}

func NewK8sRepo 

func NewK8sRepo(
	logger mlog.Logger,
	timer timer.Timer,
	data data.Data,
	fileRepo FileRepo,
	uploader uploader.Uploader,
	archiver Archiver,
	remoteExecutor ExecutorManager,
) K8sRepo

type ListAccessTokenInput 

type ListAccessTokenInput struct {
	Page, PageSize int32
	WithSoftDelete bool
	Email          string
}

type ListEventInput 

type ListEventInput struct {
	Page, PageSize int32
	ActionType     types.EventActionType
	Search         string
	OrderIDDesc    *bool
}

type ListFileInput 

type ListFileInput struct {
	Page, PageSize int32
	OrderIDDesc    *bool
	WithSoftDelete bool
}

type ListNamespaceInput 

type ListNamespaceInput struct {
	Favorite bool
	Email    string
	Page     int32
	PageSize int32
	Name     *string
	IsAdmin  bool
}

type ListProjectInput 

type ListProjectInput struct {
	Page          int32
	PageSize      int32
	OrderByIDDesc *bool
}

type ListReleaseItem 

type ListReleaseItem struct {
	Release *release.Release
	Status  string
}

type ListRepoRequest 

type ListRepoRequest struct {
	Page, PageSize int32
	Enabled        *bool
	OrderByIDDesc  *bool
	Name           string
}

type LogFn 

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

type LoginInput 

type LoginInput struct {
	Username string
	Password string
}

type LoginResponse 

type LoginResponse struct {
	Token     string
	ExpiredIn int64

	UserInfo *auth2.UserInfo
}

type Member 

type Member struct {
	ID          int
	NamespaceID int
	Email       string
}

func ToMember 

func ToMember(v *ent.Member) *Member

type MockAccessTokenRepo 

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

MockAccessTokenRepo is a mock of AccessTokenRepo interface.

func NewMockAccessTokenRepo 

func NewMockAccessTokenRepo(ctrl *gomock.Controller) *MockAccessTokenRepo

NewMockAccessTokenRepo creates a new mock instance.

func (*MockAccessTokenRepo) EXPECT 

func (m *MockAccessTokenRepo) EXPECT() *MockAccessTokenRepoMockRecorder

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

func (*MockAccessTokenRepo) Grant 

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

Grant mocks base method.

func (*MockAccessTokenRepo) Lease 

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

Lease mocks base method.

func (*MockAccessTokenRepo) List 

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

List mocks base method.

func (*MockAccessTokenRepo) Revoke 

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

Revoke mocks base method.

type MockAccessTokenRepoMockRecorder 

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

MockAccessTokenRepoMockRecorder is the mock recorder for MockAccessTokenRepo.

func (*MockAccessTokenRepoMockRecorder) Grant 

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

Grant indicates an expected call of Grant.

func (*MockAccessTokenRepoMockRecorder) Lease 

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

Lease indicates an expected call of Lease.

func (*MockAccessTokenRepoMockRecorder) List 

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

List indicates an expected call of List.

func (*MockAccessTokenRepoMockRecorder) Revoke 

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

Revoke indicates an expected call of Revoke.

type MockAuthRepo 

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

MockAuthRepo is a mock of AuthRepo interface.

func NewMockAuthRepo 

func NewMockAuthRepo(ctrl *gomock.Controller) *MockAuthRepo

NewMockAuthRepo creates a new mock instance.

func (*MockAuthRepo) EXPECT 

func (m *MockAuthRepo) EXPECT() *MockAuthRepoMockRecorder

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

func (*MockAuthRepo) Login 

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

Login mocks base method.

func (*MockAuthRepo) Settings 

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

Settings mocks base method.

func (*MockAuthRepo) Sign 

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

Sign mocks base method.

func (*MockAuthRepo) VerifyToken 

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

VerifyToken mocks base method.

type MockAuthRepoMockRecorder 

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

MockAuthRepoMockRecorder is the mock recorder for MockAuthRepo.

func (*MockAuthRepoMockRecorder) Login 

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

Login indicates an expected call of Login.

func (*MockAuthRepoMockRecorder) Settings 

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

Settings indicates an expected call of Settings.

func (*MockAuthRepoMockRecorder) Sign 

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

Sign indicates an expected call of Sign.

func (*MockAuthRepoMockRecorder) VerifyToken 

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

VerifyToken indicates an expected call of VerifyToken.

type MockChangelogRepo 

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

MockChangelogRepo is a mock of ChangelogRepo interface.

func NewMockChangelogRepo 

func NewMockChangelogRepo(ctrl *gomock.Controller) *MockChangelogRepo

NewMockChangelogRepo creates a new mock instance.

func (*MockChangelogRepo) Create 

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

Create mocks base method.

func (*MockChangelogRepo) EXPECT 

func (m *MockChangelogRepo) EXPECT() *MockChangelogRepoMockRecorder

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

func (*MockChangelogRepo) FindLastChangeByProjectID 

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

FindLastChangeByProjectID mocks base method.

func (*MockChangelogRepo) FindLastChangelogsByProjectID 

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

FindLastChangelogsByProjectID mocks base method.

type MockChangelogRepoMockRecorder 

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

MockChangelogRepoMockRecorder is the mock recorder for MockChangelogRepo.

func (*MockChangelogRepoMockRecorder) Create 

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

Create indicates an expected call of Create.

func (*MockChangelogRepoMockRecorder) FindLastChangeByProjectID 

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

FindLastChangeByProjectID indicates an expected call of FindLastChangeByProjectID.

func (*MockChangelogRepoMockRecorder) FindLastChangelogsByProjectID 

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

FindLastChangelogsByProjectID indicates an expected call of FindLastChangelogsByProjectID.

type MockEndpointRepo 

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

MockEndpointRepo is a mock of EndpointRepo interface.

func NewMockEndpointRepo 

func NewMockEndpointRepo(ctrl *gomock.Controller) *MockEndpointRepo

NewMockEndpointRepo creates a new mock instance.

func (*MockEndpointRepo) EXPECT 

func (m *MockEndpointRepo) EXPECT() *MockEndpointRepoMockRecorder

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

func (*MockEndpointRepo) InNamespace 

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

InNamespace mocks base method.

func (*MockEndpointRepo) InProject 

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

InProject mocks base method.

type MockEndpointRepoMockRecorder 

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

MockEndpointRepoMockRecorder is the mock recorder for MockEndpointRepo.

func (*MockEndpointRepoMockRecorder) InNamespace 

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

InNamespace indicates an expected call of InNamespace.

func (*MockEndpointRepoMockRecorder) InProject 

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

InProject indicates an expected call of InProject.

type MockEventRepo 

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

MockEventRepo is a mock of EventRepo interface.

func NewMockEventRepo 

func NewMockEventRepo(ctrl *gomock.Controller) *MockEventRepo

NewMockEventRepo creates a new mock instance.

func (*MockEventRepo) AuditLog 

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

AuditLog mocks base method.

func (*MockEventRepo) AuditLogWithChange 

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

AuditLogWithChange mocks base method.

func (*MockEventRepo) AuditLogWithRequest 

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

AuditLogWithRequest mocks base method.

func (*MockEventRepo) Dispatch 

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

Dispatch mocks base method.

func (*MockEventRepo) EXPECT 

func (m *MockEventRepo) EXPECT() *MockEventRepoMockRecorder

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

func (*MockEventRepo) FileAuditLog 

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

FileAuditLog mocks base method.

func (*MockEventRepo) FileAuditLogWithDuration 

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

FileAuditLogWithDuration mocks base method.

func (*MockEventRepo) HandleAuditLog 

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

HandleAuditLog mocks base method.

func (*MockEventRepo) List 

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

List mocks base method.

func (*MockEventRepo) Show 

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

Show mocks base method.

type MockEventRepoMockRecorder 

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

MockEventRepoMockRecorder is the mock recorder for MockEventRepo.

func (*MockEventRepoMockRecorder) AuditLog 

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

AuditLog indicates an expected call of AuditLog.

func (*MockEventRepoMockRecorder) AuditLogWithChange 

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

AuditLogWithChange indicates an expected call of AuditLogWithChange.

func (*MockEventRepoMockRecorder) AuditLogWithRequest 

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

AuditLogWithRequest indicates an expected call of AuditLogWithRequest.

func (*MockEventRepoMockRecorder) Dispatch 

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

Dispatch indicates an expected call of Dispatch.

func (*MockEventRepoMockRecorder) FileAuditLog 

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

FileAuditLog indicates an expected call of FileAuditLog.

func (*MockEventRepoMockRecorder) FileAuditLogWithDuration 

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

FileAuditLogWithDuration indicates an expected call of FileAuditLogWithDuration.

func (*MockEventRepoMockRecorder) HandleAuditLog 

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

HandleAuditLog indicates an expected call of HandleAuditLog.

func (*MockEventRepoMockRecorder) List 

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

List indicates an expected call of List.

func (*MockEventRepoMockRecorder) Show 

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

Show indicates an expected call of Show.

type MockExecutor 

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

MockExecutor is a mock of Executor interface.

func NewMockExecutor 

func NewMockExecutor(ctrl *gomock.Controller) *MockExecutor

NewMockExecutor creates a new mock instance.

func (*MockExecutor) EXPECT 

func (m *MockExecutor) EXPECT() *MockExecutorMockRecorder

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

func (*MockExecutor) Execute 

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

Execute mocks base method.

func (*MockExecutor) WithCommand 

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

WithCommand mocks base method.

func (*MockExecutor) WithContainer 

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

WithContainer mocks base method.

func (*MockExecutor) WithMethod 

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

WithMethod mocks base method.

type MockExecutorManager 

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

MockExecutorManager is a mock of ExecutorManager interface.

func NewMockExecutorManager 

func NewMockExecutorManager(ctrl *gomock.Controller) *MockExecutorManager

NewMockExecutorManager creates a new mock instance.

func (*MockExecutorManager) EXPECT 

func (m *MockExecutorManager) EXPECT() *MockExecutorManagerMockRecorder

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

func (*MockExecutorManager) New 

func (m *MockExecutorManager) New() Executor

New mocks base method.

func (*MockExecutorManager) NewFileCopy 

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

NewFileCopy mocks base method.

type MockExecutorManagerMockRecorder 

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

MockExecutorManagerMockRecorder is the mock recorder for MockExecutorManager.

func (*MockExecutorManagerMockRecorder) New 

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

New indicates an expected call of New.

func (*MockExecutorManagerMockRecorder) NewFileCopy 

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

NewFileCopy indicates an expected call of NewFileCopy.

type MockExecutorMockRecorder 

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

MockExecutorMockRecorder is the mock recorder for MockExecutor.

func (*MockExecutorMockRecorder) Execute 

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

Execute indicates an expected call of Execute.

func (*MockExecutorMockRecorder) WithCommand 

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

WithCommand indicates an expected call of WithCommand.

func (*MockExecutorMockRecorder) WithContainer 

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

WithContainer indicates an expected call of WithContainer.

func (*MockExecutorMockRecorder) WithMethod 

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

WithMethod indicates an expected call of WithMethod.

type MockFileRepo 

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

MockFileRepo is a mock of FileRepo interface.

func NewMockFileRepo 

func NewMockFileRepo(ctrl *gomock.Controller) *MockFileRepo

NewMockFileRepo creates a new mock instance.

func (*MockFileRepo) Create 

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

Create mocks base method.

func (*MockFileRepo) Delete 

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

Delete mocks base method.

func (*MockFileRepo) DiskInfo 

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

DiskInfo mocks base method.

func (*MockFileRepo) EXPECT 

func (m *MockFileRepo) EXPECT() *MockFileRepoMockRecorder

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

func (*MockFileRepo) GetByID 

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

GetByID mocks base method.

func (*MockFileRepo) List 

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

List mocks base method.

func (*MockFileRepo) MaxUploadSize 

func (m *MockFileRepo) MaxUploadSize() uint64

MaxUploadSize mocks base method.

func (*MockFileRepo) NewDisk 

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

NewDisk mocks base method.

func (*MockFileRepo) NewFile 

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

NewFile mocks base method.

func (*MockFileRepo) NewRecorder 

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

NewRecorder mocks base method.

func (*MockFileRepo) ShowRecords 

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

ShowRecords mocks base method.

func (*MockFileRepo) StreamUploadFile 

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

StreamUploadFile mocks base method.

func (*MockFileRepo) Update 

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

Update mocks base method.

type MockFileRepoMockRecorder 

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

MockFileRepoMockRecorder is the mock recorder for MockFileRepo.

func (*MockFileRepoMockRecorder) Create 

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

Create indicates an expected call of Create.

func (*MockFileRepoMockRecorder) Delete 

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

Delete indicates an expected call of Delete.

func (*MockFileRepoMockRecorder) DiskInfo 

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

DiskInfo indicates an expected call of DiskInfo.

func (*MockFileRepoMockRecorder) GetByID 

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

GetByID indicates an expected call of GetByID.

func (*MockFileRepoMockRecorder) List 

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

List indicates an expected call of List.

func (*MockFileRepoMockRecorder) MaxUploadSize 

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

MaxUploadSize indicates an expected call of MaxUploadSize.

func (*MockFileRepoMockRecorder) NewDisk 

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

NewDisk indicates an expected call of NewDisk.

func (*MockFileRepoMockRecorder) NewFile 

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

NewFile indicates an expected call of NewFile.

func (*MockFileRepoMockRecorder) NewRecorder 

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

NewRecorder indicates an expected call of NewRecorder.

func (*MockFileRepoMockRecorder) ShowRecords 

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

ShowRecords indicates an expected call of ShowRecords.

func (*MockFileRepoMockRecorder) StreamUploadFile 

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

StreamUploadFile indicates an expected call of StreamUploadFile.

func (*MockFileRepoMockRecorder) Update 

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

Update indicates an expected call of Update.

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) AllBranches 

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

AllBranches mocks base method.

func (*MockGitRepo) AllProjects 

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

AllProjects 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) GetByProjectID 

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

GetByProjectID mocks base method.

func (*MockGitRepo) GetChartValuesYaml 

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

GetChartValuesYaml mocks base method.

func (*MockGitRepo) GetCommit 

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

GetCommit mocks base method.

func (*MockGitRepo) GetCommitPipeline 

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

GetCommitPipeline mocks base method.

func (*MockGitRepo) GetFileContentWithBranch 

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

GetFileContentWithBranch mocks base method.

func (*MockGitRepo) GetProject 

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

GetProject mocks base method.

func (*MockGitRepo) ListCommits 

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

ListCommits mocks base method.

type MockGitRepoMockRecorder 

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

MockGitRepoMockRecorder is the mock recorder for MockGitRepo.

func (*MockGitRepoMockRecorder) AllBranches 

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

AllBranches indicates an expected call of AllBranches.

func (*MockGitRepoMockRecorder) AllProjects 

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

AllProjects indicates an expected call of AllProjects.

func (*MockGitRepoMockRecorder) GetByProjectID 

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

GetByProjectID indicates an expected call of GetByProjectID.

func (*MockGitRepoMockRecorder) GetChartValuesYaml 

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

GetChartValuesYaml indicates an expected call of GetChartValuesYaml.

func (*MockGitRepoMockRecorder) GetCommit 

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

GetCommit indicates an expected call of GetCommit.

func (*MockGitRepoMockRecorder) GetCommitPipeline 

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

GetCommitPipeline indicates an expected call of GetCommitPipeline.

func (*MockGitRepoMockRecorder) GetFileContentWithBranch 

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

GetFileContentWithBranch indicates an expected call of GetFileContentWithBranch.

func (*MockGitRepoMockRecorder) GetProject 

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

GetProject indicates an expected call of GetProject.

func (*MockGitRepoMockRecorder) ListCommits 

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

ListCommits indicates an expected call of ListCommits.

type MockHelmerRepo 

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

MockHelmerRepo is a mock of HelmerRepo interface.

func NewMockHelmerRepo 

func NewMockHelmerRepo(ctrl *gomock.Controller) *MockHelmerRepo

NewMockHelmerRepo creates a new mock instance.

func (*MockHelmerRepo) EXPECT 

func (m *MockHelmerRepo) EXPECT() *MockHelmerRepoMockRecorder

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

func (*MockHelmerRepo) PackageChart 

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

PackageChart mocks base method.

func (*MockHelmerRepo) ReleaseStatus 

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

ReleaseStatus mocks base method.

func (*MockHelmerRepo) Rollback 

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

Rollback mocks base method.

func (*MockHelmerRepo) Uninstall 

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

Uninstall mocks base method.

func (*MockHelmerRepo) UpgradeOrInstall 

func (m *MockHelmerRepo) UpgradeOrInstall(arg0 context.Context, arg1, arg2 string, arg3 *chart.Chart, arg4 *values.Options, arg5 WrapLogFn, arg6 bool, arg7 int64, arg8 bool, arg9 string) (*release.Release, error)

UpgradeOrInstall mocks base method.

type MockHelmerRepoMockRecorder 

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

MockHelmerRepoMockRecorder is the mock recorder for MockHelmerRepo.

func (*MockHelmerRepoMockRecorder) PackageChart 

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

PackageChart indicates an expected call of PackageChart.

func (*MockHelmerRepoMockRecorder) ReleaseStatus 

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

ReleaseStatus indicates an expected call of ReleaseStatus.

func (*MockHelmerRepoMockRecorder) Rollback 

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

Rollback indicates an expected call of Rollback.

func (*MockHelmerRepoMockRecorder) Uninstall 

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

Uninstall indicates an expected call of Uninstall.

func (*MockHelmerRepoMockRecorder) UpgradeOrInstall 

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

UpgradeOrInstall indicates an expected call of UpgradeOrInstall.

type MockK8sRepo 

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

MockK8sRepo is a mock of K8sRepo interface.

func NewMockK8sRepo 

func NewMockK8sRepo(ctrl *gomock.Controller) *MockK8sRepo

NewMockK8sRepo creates a new mock instance.

func (*MockK8sRepo) AddTlsSecret 

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

AddTlsSecret mocks base method.

func (*MockK8sRepo) ClusterInfo 

func (m *MockK8sRepo) ClusterInfo() *ClusterInfo

ClusterInfo mocks base method.

func (*MockK8sRepo) CopyFileToPod 

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

CopyFileToPod mocks base method.

func (*MockK8sRepo) CopyFromPod 

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

CopyFromPod mocks base method.

func (*MockK8sRepo) CreateDockerSecret 

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

CreateDockerSecret mocks base method.

func (*MockK8sRepo) CreateNamespace 

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

CreateNamespace mocks base method.

func (*MockK8sRepo) DeleteNamespace 

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

DeleteNamespace mocks base method.

func (*MockK8sRepo) DeleteSecret 

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

DeleteSecret mocks base method.

func (*MockK8sRepo) EXPECT 

func (m *MockK8sRepo) EXPECT() *MockK8sRepoMockRecorder

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

func (*MockK8sRepo) Execute 

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

Execute mocks base method.

func (*MockK8sRepo) FindDefaultContainer 

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

FindDefaultContainer mocks base method.

func (*MockK8sRepo) GetAllPodMetrics 

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

GetAllPodMetrics mocks base method.

func (*MockK8sRepo) GetCpuAndMemory 

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

GetCpuAndMemory mocks base method.

func (*MockK8sRepo) GetCpuAndMemoryInNamespace 

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

GetCpuAndMemoryInNamespace mocks base method.

func (*MockK8sRepo) GetCpuAndMemoryQuantity 

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

GetCpuAndMemoryQuantity mocks base method.

func (*MockK8sRepo) GetNamespace 

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

GetNamespace mocks base method.

func (*MockK8sRepo) GetPod 

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

GetPod mocks base method.

func (*MockK8sRepo) GetPodLogs 

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

GetPodLogs mocks base method.

func (*MockK8sRepo) GetPodMetrics 

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

GetPodMetrics mocks base method.

func (*MockK8sRepo) GetPodSelectorsByManifest 

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

GetPodSelectorsByManifest mocks base method.

func (*MockK8sRepo) IsPodRunning 

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

IsPodRunning mocks base method.

func (*MockK8sRepo) ListEvents 

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

ListEvents mocks base method.

func (*MockK8sRepo) LogStream 

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

LogStream mocks base method.

func (*MockK8sRepo) SplitManifests 

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

SplitManifests mocks base method.

type MockK8sRepoMockRecorder 

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

MockK8sRepoMockRecorder is the mock recorder for MockK8sRepo.

func (*MockK8sRepoMockRecorder) AddTlsSecret 

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

AddTlsSecret indicates an expected call of AddTlsSecret.

func (*MockK8sRepoMockRecorder) ClusterInfo 

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

ClusterInfo indicates an expected call of ClusterInfo.

func (*MockK8sRepoMockRecorder) CopyFileToPod 

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

CopyFileToPod indicates an expected call of CopyFileToPod.

func (*MockK8sRepoMockRecorder) CopyFromPod 

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

CopyFromPod indicates an expected call of CopyFromPod.

func (*MockK8sRepoMockRecorder) CreateDockerSecret 

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

CreateDockerSecret indicates an expected call of CreateDockerSecret.

func (*MockK8sRepoMockRecorder) CreateNamespace 

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

CreateNamespace indicates an expected call of CreateNamespace.

func (*MockK8sRepoMockRecorder) DeleteNamespace 

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

DeleteNamespace indicates an expected call of DeleteNamespace.

func (*MockK8sRepoMockRecorder) DeleteSecret 

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

DeleteSecret indicates an expected call of DeleteSecret.

func (*MockK8sRepoMockRecorder) Execute 

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

Execute indicates an expected call of Execute.

func (*MockK8sRepoMockRecorder) FindDefaultContainer 

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

FindDefaultContainer indicates an expected call of FindDefaultContainer.

func (*MockK8sRepoMockRecorder) GetAllPodMetrics 

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

GetAllPodMetrics indicates an expected call of GetAllPodMetrics.

func (*MockK8sRepoMockRecorder) GetCpuAndMemory 

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

GetCpuAndMemory indicates an expected call of GetCpuAndMemory.

func (*MockK8sRepoMockRecorder) GetCpuAndMemoryInNamespace 

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

GetCpuAndMemoryInNamespace indicates an expected call of GetCpuAndMemoryInNamespace.

func (*MockK8sRepoMockRecorder) GetCpuAndMemoryQuantity 

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

GetCpuAndMemoryQuantity indicates an expected call of GetCpuAndMemoryQuantity.

func (*MockK8sRepoMockRecorder) GetNamespace 

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

GetNamespace indicates an expected call of GetNamespace.

func (*MockK8sRepoMockRecorder) GetPod 

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

GetPod indicates an expected call of GetPod.

func (*MockK8sRepoMockRecorder) GetPodLogs 

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

GetPodLogs indicates an expected call of GetPodLogs.

func (*MockK8sRepoMockRecorder) GetPodMetrics 

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

GetPodMetrics indicates an expected call of GetPodMetrics.

func (*MockK8sRepoMockRecorder) GetPodSelectorsByManifest 

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

GetPodSelectorsByManifest indicates an expected call of GetPodSelectorsByManifest.

func (*MockK8sRepoMockRecorder) IsPodRunning 

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

IsPodRunning indicates an expected call of IsPodRunning.

func (*MockK8sRepoMockRecorder) ListEvents 

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

ListEvents indicates an expected call of ListEvents.

func (*MockK8sRepoMockRecorder) LogStream 

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

LogStream indicates an expected call of LogStream.

func (*MockK8sRepoMockRecorder) SplitManifests 

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

SplitManifests indicates an expected call of SplitManifests.

type MockNamespaceRepo 

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

MockNamespaceRepo is a mock of NamespaceRepo interface.

func NewMockNamespaceRepo 

func NewMockNamespaceRepo(ctrl *gomock.Controller) *MockNamespaceRepo

NewMockNamespaceRepo creates a new mock instance.

func (*MockNamespaceRepo) CanAccess 

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

CanAccess mocks base method.

func (*MockNamespaceRepo) Create 

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

Create mocks base method.

func (*MockNamespaceRepo) Delete 

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

Delete mocks base method.

func (*MockNamespaceRepo) EXPECT 

func (m *MockNamespaceRepo) EXPECT() *MockNamespaceRepoMockRecorder

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

func (*MockNamespaceRepo) Favorite 

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

Favorite mocks base method.

func (*MockNamespaceRepo) FindByName 

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

FindByName mocks base method.

func (*MockNamespaceRepo) GetMarsNamespace 

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

GetMarsNamespace mocks base method.

func (*MockNamespaceRepo) IsOwner 

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

IsOwner mocks base method.

func (*MockNamespaceRepo) List 

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

List mocks base method.

func (*MockNamespaceRepo) Show 

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

Show mocks base method.

func (*MockNamespaceRepo) SyncMembers 

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

SyncMembers mocks base method.

func (*MockNamespaceRepo) Transfer 

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

Transfer mocks base method.

func (*MockNamespaceRepo) Update 

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

Update mocks base method.

func (*MockNamespaceRepo) UpdatePrivate 

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

UpdatePrivate mocks base method.

type MockNamespaceRepoMockRecorder 

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

MockNamespaceRepoMockRecorder is the mock recorder for MockNamespaceRepo.

func (*MockNamespaceRepoMockRecorder) CanAccess 

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

CanAccess indicates an expected call of CanAccess.

func (*MockNamespaceRepoMockRecorder) Create 

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

Create indicates an expected call of Create.

func (*MockNamespaceRepoMockRecorder) Delete 

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

Delete indicates an expected call of Delete.

func (*MockNamespaceRepoMockRecorder) Favorite 

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

Favorite indicates an expected call of Favorite.

func (*MockNamespaceRepoMockRecorder) FindByName 

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

FindByName indicates an expected call of FindByName.

func (*MockNamespaceRepoMockRecorder) GetMarsNamespace 

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

GetMarsNamespace indicates an expected call of GetMarsNamespace.

func (*MockNamespaceRepoMockRecorder) IsOwner 

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

IsOwner indicates an expected call of IsOwner.

func (*MockNamespaceRepoMockRecorder) List 

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

List indicates an expected call of List.

func (*MockNamespaceRepoMockRecorder) Show 

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

Show indicates an expected call of Show.

func (*MockNamespaceRepoMockRecorder) SyncMembers 

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

SyncMembers indicates an expected call of SyncMembers.

func (*MockNamespaceRepoMockRecorder) Transfer 

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

Transfer indicates an expected call of Transfer.

func (*MockNamespaceRepoMockRecorder) Update 

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

Update indicates an expected call of Update.

func (*MockNamespaceRepoMockRecorder) UpdatePrivate 

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

UpdatePrivate indicates an expected call of UpdatePrivate.

type MockPictureRepo 

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

MockPictureRepo is a mock of PictureRepo interface.

func NewMockPictureRepo 

func NewMockPictureRepo(ctrl *gomock.Controller) *MockPictureRepo

NewMockPictureRepo creates a new mock instance.

func (*MockPictureRepo) EXPECT 

func (m *MockPictureRepo) EXPECT() *MockPictureRepoMockRecorder

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

func (*MockPictureRepo) Get 

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

Get mocks base method.

type MockPictureRepoMockRecorder 

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

MockPictureRepoMockRecorder is the mock recorder for MockPictureRepo.

func (*MockPictureRepoMockRecorder) Get 

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

Get indicates an expected call of Get.

type MockProjectRepo 

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

MockProjectRepo is a mock of ProjectRepo interface.

func NewMockProjectRepo 

func NewMockProjectRepo(ctrl *gomock.Controller) *MockProjectRepo

NewMockProjectRepo creates a new mock instance.

func (*MockProjectRepo) Create 

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

Create mocks base method.

func (*MockProjectRepo) Delete 

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

Delete mocks base method.

func (*MockProjectRepo) EXPECT 

func (m *MockProjectRepo) EXPECT() *MockProjectRepoMockRecorder

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

func (*MockProjectRepo) FindByName 

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

FindByName mocks base method.

func (*MockProjectRepo) FindByVersion 

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

FindByVersion mocks base method.

func (*MockProjectRepo) GetAllActiveContainers 

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

GetAllActiveContainers mocks base method.

func (*MockProjectRepo) GetPreOccupiedLenByValuesYaml 

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

GetPreOccupiedLenByValuesYaml mocks base method.

func (*MockProjectRepo) GetProjectEndpointsInNamespace 

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

GetProjectEndpointsInNamespace mocks base method.

func (*MockProjectRepo) List 

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

List mocks base method.

func (*MockProjectRepo) Show 

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

Show mocks base method.

func (*MockProjectRepo) UpdateDeployStatus 

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

UpdateDeployStatus mocks base method.

func (*MockProjectRepo) UpdateProject 

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

UpdateProject mocks base method.

func (*MockProjectRepo) UpdateStatusByVersion 

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

UpdateStatusByVersion mocks base method.

func (*MockProjectRepo) UpdateVersion 

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

UpdateVersion mocks base method.

func (*MockProjectRepo) Version added in v5.0.7 

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

Version mocks base method.

type MockProjectRepoMockRecorder 

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

MockProjectRepoMockRecorder is the mock recorder for MockProjectRepo.

func (*MockProjectRepoMockRecorder) Create 

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

Create indicates an expected call of Create.

func (*MockProjectRepoMockRecorder) Delete 

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

Delete indicates an expected call of Delete.

func (*MockProjectRepoMockRecorder) FindByName 

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

FindByName indicates an expected call of FindByName.

func (*MockProjectRepoMockRecorder) FindByVersion 

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

FindByVersion indicates an expected call of FindByVersion.

func (*MockProjectRepoMockRecorder) GetAllActiveContainers 

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

GetAllActiveContainers indicates an expected call of GetAllActiveContainers.

func (*MockProjectRepoMockRecorder) GetPreOccupiedLenByValuesYaml 

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

GetPreOccupiedLenByValuesYaml indicates an expected call of GetPreOccupiedLenByValuesYaml.

func (*MockProjectRepoMockRecorder) GetProjectEndpointsInNamespace 

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

GetProjectEndpointsInNamespace indicates an expected call of GetProjectEndpointsInNamespace.

func (*MockProjectRepoMockRecorder) List 

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

List indicates an expected call of List.

func (*MockProjectRepoMockRecorder) Show 

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

Show indicates an expected call of Show.

func (*MockProjectRepoMockRecorder) UpdateDeployStatus 

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

UpdateDeployStatus indicates an expected call of UpdateDeployStatus.

func (*MockProjectRepoMockRecorder) UpdateProject 

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

UpdateProject indicates an expected call of UpdateProject.

func (*MockProjectRepoMockRecorder) UpdateStatusByVersion 

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

UpdateStatusByVersion indicates an expected call of UpdateStatusByVersion.

func (*MockProjectRepoMockRecorder) UpdateVersion 

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

UpdateVersion indicates an expected call of UpdateVersion.

func (*MockProjectRepoMockRecorder) Version added in v5.0.7 

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

Version indicates an expected call of Version.

type MockRecorder 

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

MockRecorder is a mock of Recorder interface.

func NewMockRecorder 

func NewMockRecorder(ctrl *gomock.Controller) *MockRecorder

NewMockRecorder creates a new mock instance.

func (*MockRecorder) Close 

func (m *MockRecorder) Close() error

Close mocks base method.

func (*MockRecorder) Container 

func (m *MockRecorder) Container() *Container

Container mocks base method.

func (*MockRecorder) Duration 

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

Duration mocks base method.

func (*MockRecorder) EXPECT 

func (m *MockRecorder) EXPECT() *MockRecorderMockRecorder

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

func (*MockRecorder) File 

func (m *MockRecorder) File() *File

File mocks base method.

func (*MockRecorder) GetShell 

func (m *MockRecorder) GetShell() string

GetShell mocks base method.

func (*MockRecorder) Resize 

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

Resize mocks base method.

func (*MockRecorder) SetShell 

func (m *MockRecorder) SetShell(arg0 string)

SetShell mocks base method.

func (*MockRecorder) User 

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

User mocks base method.

func (*MockRecorder) Write 

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

Write mocks base method.

type MockRecorderMockRecorder 

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

MockRecorderMockRecorder is the mock recorder for MockRecorder.

func (*MockRecorderMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockRecorderMockRecorder) Container 

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

Container indicates an expected call of Container.

func (*MockRecorderMockRecorder) Duration 

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

Duration indicates an expected call of Duration.

func (*MockRecorderMockRecorder) File 

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

File indicates an expected call of File.

func (*MockRecorderMockRecorder) GetShell 

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

GetShell indicates an expected call of GetShell.

func (*MockRecorderMockRecorder) Resize 

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

Resize indicates an expected call of Resize.

func (*MockRecorderMockRecorder) SetShell 

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

SetShell indicates an expected call of SetShell.

func (*MockRecorderMockRecorder) User 

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

User indicates an expected call of User.

func (*MockRecorderMockRecorder) Write 

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

Write indicates an expected call of Write.

type MockRepoRepo 

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

MockRepoRepo is a mock of RepoRepo interface.

func NewMockRepoRepo 

func NewMockRepoRepo(ctrl *gomock.Controller) *MockRepoRepo

NewMockRepoRepo creates a new mock instance.

func (*MockRepoRepo) All 

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

All mocks base method.

func (*MockRepoRepo) Clone 

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

Clone mocks base method.

func (*MockRepoRepo) Create 

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

Create mocks base method.

func (*MockRepoRepo) Delete 

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

Delete mocks base method.

func (*MockRepoRepo) EXPECT 

func (m *MockRepoRepo) EXPECT() *MockRepoRepoMockRecorder

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

func (*MockRepoRepo) List 

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

List mocks base method.

func (*MockRepoRepo) Show 

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

Show mocks base method.

func (*MockRepoRepo) ToggleEnabled 

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

ToggleEnabled mocks base method.

func (*MockRepoRepo) Update 

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

Update mocks base method.

type MockRepoRepoMockRecorder 

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

MockRepoRepoMockRecorder is the mock recorder for MockRepoRepo.

func (*MockRepoRepoMockRecorder) All 

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

All indicates an expected call of All.

func (*MockRepoRepoMockRecorder) Clone 

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

Clone indicates an expected call of Clone.

func (*MockRepoRepoMockRecorder) Create 

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

Create indicates an expected call of Create.

func (*MockRepoRepoMockRecorder) Delete 

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

Delete indicates an expected call of Delete.

func (*MockRepoRepoMockRecorder) List 

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

List indicates an expected call of List.

func (*MockRepoRepoMockRecorder) Show 

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

Show indicates an expected call of Show.

func (*MockRepoRepoMockRecorder) ToggleEnabled 

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

ToggleEnabled indicates an expected call of ToggleEnabled.

func (*MockRepoRepoMockRecorder) Update 

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

Update indicates an expected call of Update.

type Namespace 

type Namespace struct {
	ID               int
	CreatedAt        time.Time
	UpdatedAt        time.Time
	DeletedAt        *time.Time
	Name             string
	ImagePullSecrets []string
	Description      string
	Private          bool
	CreatorEmail     string

	Projects  []*Project
	Favorites []*Favorite
	Members   []*Member
}

Namespace is the model entity for the Namespace schema.

func ToNamespace 

func ToNamespace(namespace *ent.Namespace) *Namespace

func (*Namespace) GetImagePullSecrets 

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

type NamespaceCreatedData 

type NamespaceCreatedData struct {
	NsModel  *Namespace
	NsK8sObj *corev1.Namespace
}

type NamespaceDeletedData 

type NamespaceDeletedData struct {
	ID int
}

type NamespaceRepo 

type NamespaceRepo interface {
	List(ctx context.Context, input *ListNamespaceInput) ([]*Namespace, *pagination.Pagination, error)
	Create(ctx context.Context, input *CreateNamespaceInput) (*Namespace, error)
	Show(ctx context.Context, id int) (*Namespace, error)
	Update(ctx context.Context, input *UpdateNamespaceInput) (*Namespace, error)
	Delete(ctx context.Context, id int) error
	GetMarsNamespace(name string) string
	FindByName(ctx context.Context, name string) (*Namespace, error)
	Favorite(ctx context.Context, input *FavoriteNamespaceInput) error
	SyncMembers(ctx context.Context, namespaceID int, memberEmails []string) (*Namespace, error)
	UpdatePrivate(ctx context.Context, namespaceID int, private bool) (*Namespace, error)
	IsOwner(ctx context.Context, namespaceID int, user *auth.UserInfo) (bool, error)
	CanAccess(ctx context.Context, namespaceID int, user *auth.UserInfo) bool
	Transfer(ctx context.Context, id int, email string) (*Namespace, error)
}

func NewNamespaceRepo 

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

type PictureRepo 

type PictureRepo interface {
	Get(ctx context.Context, random bool) (*application.PictureItem, error)
}

func NewPictureRepo 

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

type Pipeline 

type Pipeline struct {
	Status application.Status
	WebURL string
}

type Project 

type Project struct {
	ID               int
	CreatedAt        time.Time
	UpdatedAt        time.Time
	DeletedAt        *time.Time
	Name             string
	GitProjectID     int
	GitBranch        string
	GitCommit        string
	Config           string
	OverrideValues   string
	DockerImage      []string
	PodSelectors     []string
	Atomic           bool
	DeployStatus     types.Deploy
	EnvValues        []*types.KeyValue
	ExtraValues      []*websocket_pb.ExtraValue
	FinalExtraValues []*websocket_pb.ExtraValue
	Version          int
	ConfigType       string
	GitCommitWebURL  string
	GitCommitTitle   string
	GitCommitAuthor  string
	GitCommitDate    *time.Time
	NamespaceID      int
	RepoID           int

	// 用户前端表单 elements
	// 和 extraValues 的区别是
	// extraValues 是系统默认的额外值
	// elements 是 repoImpl 最新的
	Elements []*types.KeyValue

	Namespace *Namespace
	Repo      *Repo
	Manifest  []string
}

func ToProject 

func ToProject(project *ent.Project) *Project

type ProjectChangedData 

type ProjectChangedData struct {
	ID int

	Username string
}

type ProjectDeletedPayload 

type ProjectDeletedPayload struct {
	NamespaceID int
	ProjectID   int
}

type ProjectRepo 

type ProjectRepo interface {
	GetAllActiveContainers(ctx context.Context, id int) ([]*types.StateContainer, error)
	GetProjectEndpointsInNamespace(ctx context.Context, namespace string, projectIDs ...int) ([]*types.ServiceEndpoint, error)
	GetPreOccupiedLenByValuesYaml(values string) int
	List(ctx context.Context, input *ListProjectInput) ([]*Project, *pagination.Pagination, error)
	Create(ctx context.Context, project *CreateProjectInput) (*Project, error)
	Show(ctx context.Context, id int) (*Project, error)
	Version(ctx context.Context, id int) (int, error)
	Delete(ctx context.Context, id int) error
	FindByName(ctx context.Context, name string, nsID int) (*Project, error)
	UpdateDeployStatus(ctx context.Context, id int, status types.Deploy) (*Project, error)
	UpdateVersion(ctx context.Context, id int, version int) (*Project, error)
	FindByVersion(ctx context.Context, id, version int) (*Project, error)
	UpdateStatusByVersion(ctx context.Context, id int, status types.Deploy, version int) (*Project, error)
	UpdateProject(ctx context.Context, input *UpdateProjectInput) (*Project, error)
}

func NewProjectRepo 

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

type Recorder 

type Recorder interface {
	Resize(width, height uint16)
	Write(p []byte) (n int, err error)
	Close() error
	SetShell(string)
	GetShell() string
	File() *File
	Duration() time.Duration
	User() *auth.UserInfo
	Container() *Container
}

type ReleaseList 

type ReleaseList map[string]ListReleaseItem

func (ReleaseList) Add 

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

func (ReleaseList) GetStatus 

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

type Repo 

type Repo struct {
	ID             int          `json:"id"`
	CreatedAt      time.Time    `json:"-"`
	UpdatedAt      time.Time    `json:"-"`
	DeletedAt      *time.Time   `json:"-"`
	Name           string       `json:"name"`
	DefaultBranch  string       `json:"default_branch"`
	GitProjectName string       `json:"git_project_name"`
	GitProjectID   int32        `json:"git_project_id"`
	Enabled        bool         `json:"enabled"`
	NeedGitRepo    bool         `json:"need_git_repo"`
	MarsConfig     *mars.Config `json:"mars_config"`
	Description    string       `json:"description"`

	Projects []*Project `json:"projects"`
}

func ToRepo 

func ToRepo(data *ent.Repo) *Repo

func (*Repo) GetMarsConfig 

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

type RepoRepo 

type RepoRepo interface {
	All(ctx context.Context, in *AllRepoRequest) ([]*Repo, error)
	List(ctx context.Context, in *ListRepoRequest) ([]*Repo, *pagination.Pagination, error)
	Create(ctx context.Context, in *CreateRepoInput) (*Repo, error)
	Show(ctx context.Context, id int) (*Repo, error)
	Update(ctx context.Context, in *UpdateRepoInput) (*Repo, error)
	Delete(ctx context.Context, id int) error
	Clone(ctx context.Context, input *CloneRepoInput) (*Repo, error)
	ToggleEnabled(ctx context.Context, id int, enabled bool) (*Repo, error)
}

func NewRepo 

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

type RuntimeObjectList 

type RuntimeObjectList []runtime.Object

func FilterRuntimeObjectFromManifests 

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

func (RuntimeObjectList) Has 

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

type SortStatePod 

type SortStatePod []StatePod

func (SortStatePod) Len 

func (s SortStatePod) Len() int

func (SortStatePod) Less 

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

func (SortStatePod) Swap 

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

type StatePod 

type StatePod struct {
	IsOld       bool
	Terminating bool
	Pending     bool
	OrderIndex  int
	Pod         *corev1.Pod
}

type StreamUploadFileRequest 

type StreamUploadFileRequest struct {
	Namespace, Pod, Container string
	Username                  string
	FileName                  string
	FileData                  chan []byte
}

type StringYamlPrettier 

type StringYamlPrettier struct {
	Str string
}

func (*StringYamlPrettier) PrettyYaml 

func (s *StringYamlPrettier) PrettyYaml() string

type UpdateFileRequest 

type UpdateFileRequest struct {
	ID            int
	ContainerPath string
	Namespace     string
	Pod           string
	Container     string
}

type UpdateNamespaceInput 

type UpdateNamespaceInput struct {
	ID          int
	Description string
}

type UpdateProjectInput 

type UpdateProjectInput struct {
	ID         int
	GitBranch  string
	GitCommit  string
	Config     string
	Atomic     *bool
	ConfigType string

	PodSelectors     []string
	DockerImage      []string
	GitCommitTitle   string
	GitCommitWebURL  string
	GitCommitAuthor  string
	GitCommitDate    *time.Time
	ExtraValues      []*websocket_pb.ExtraValue
	FinalExtraValues []*websocket_pb.ExtraValue
	EnvValues        []*types.KeyValue
	OverrideValues   string
	Manifest         []string
}

type UpdateRepoInput 

type UpdateRepoInput struct {
	ID           int32
	Name         string
	NeedGitRepo  bool
	GitProjectID *int32
	MarsConfig   *mars.Config
	Description  string
}

type WrapLogFn 

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

func (WrapLogFn) UnWrap 

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

type YamlPrettier 

type YamlPrettier interface {
	PrettyYaml() string
}

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.