Help us shape the future of Go! Take the 2026 Go Developer Survey

application

package
v3.5.6 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 2026 License: Apache-2.0 Imports: 78 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ReconnectCode    = 1
	ReconnectMessage = "\nReconnect because the token was refreshed...\n"
)
View Source 
const EndOfTransmission = "\u0004"

Variables

View Source 
var (
	ErrCacheMiss = cacheutil.ErrCacheMiss
)

Functions

func NewHandler 

func NewHandler(appLister applisters.ApplicationLister, namespace string, enabledNamespaces []string, db db.ArgoDB, appResourceTree AppResourceTreeFn, allowedShells []string, sessionManager *util_session.SessionManager, terminalOptions *TerminalOptions) *terminalHandler

NewHandler returns a new terminal handler.

Types

type AppResourceTreeFn 

type AppResourceTreeFn func(ctx context.Context, app *v1alpha1.Application) (*v1alpha1.ApplicationTree, error)

func NewServer 

func NewServer(
	namespace string,
	kubeclientset kubernetes.Interface,
	appclientset appclientset.Interface,
	appLister applisters.ApplicationLister,
	appInformer cache.SharedIndexInformer,
	appBroadcaster broadcast.Broadcaster[v1alpha1.ApplicationWatchEvent],
	repoClientset apiclient.Clientset,
	cache *servercache.Cache,
	kubectl kube.Kubectl,
	db db.ArgoDB,
	enf *rbac.Enforcer,
	projectLock sync.KeyLock,
	settingsMgr *settings.SettingsManager,
	projInformer cache.SharedIndexInformer,
	enabledNamespaces []string,
	enableK8sEvent []string,
	syncWithReplaceAllowed bool,
) (application.ApplicationServiceServer, AppResourceTreeFn)

NewServer returns a new instance of the Application service

type GetSettingsFunc 

type GetSettingsFunc func() (*settings.ArgoCDSettings, error)

type PtyHandler 

type PtyHandler interface {
	io.Reader
	io.Writer
	remotecommand.TerminalSizeQueue
}

PtyHandler is what remotecommand expects from a pty

type Server 

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

Server provides an Application service

func (*Server) Create 

func (s *Server) Create(ctx context.Context, q *application.ApplicationCreateRequest) (*v1alpha1.Application, error)

Create creates an application

func (*Server) Delete 

func (s *Server) Delete(ctx context.Context, q *application.ApplicationDeleteRequest) (*application.ApplicationResponse, error)

Delete removes an application and all associated resources

func (*Server) DeleteResource 

func (s *Server) DeleteResource(ctx context.Context, q *application.ApplicationResourceDeleteRequest) (*application.ApplicationResponse, error)

DeleteResource deletes a specified resource

func (*Server) Get 

func (s *Server) Get(ctx context.Context, q *application.ApplicationQuery) (*v1alpha1.Application, error)

Get returns an application by name

func (*Server) GetApplicationSyncWindows 

func (s *Server) GetApplicationSyncWindows(ctx context.Context, q *application.ApplicationSyncWindowsQuery) (*application.ApplicationSyncWindowsResponse, error)

func (*Server) GetManifests 

func (s *Server) GetManifests(ctx context.Context, q *application.ApplicationManifestQuery) (*apiclient.ManifestResponse, error)

GetManifests returns application manifests

func (*Server) GetManifestsWithFiles 

func (s *Server) GetManifestsWithFiles(stream application.ApplicationService_GetManifestsWithFilesServer) error

func (*Server) GetOCIMetadata added in v3.1.0 

func (s *Server) GetOCIMetadata(ctx context.Context, q *application.RevisionMetadataQuery) (*v1alpha1.OCIMetadata, error)

func (*Server) GetResource 

func (s *Server) GetResource(ctx context.Context, q *application.ApplicationResourceRequest) (*application.ApplicationResourceResponse, error)

func (*Server) List 

func (s *Server) List(ctx context.Context, q *application.ApplicationQuery) (*v1alpha1.ApplicationList, error)

List returns list of applications 

func (s *Server) ListLinks(ctx context.Context, req *application.ListAppLinksRequest) (*application.LinksResponse, error)

func (*Server) ListResourceActions 

func (s *Server) ListResourceActions(ctx context.Context, q *application.ApplicationResourceRequest) (*application.ResourceActionsListResponse, error)

func (*Server) ListResourceEvents 

func (s *Server) ListResourceEvents(ctx context.Context, q *application.ApplicationResourceEventsQuery) (*eventspb.EventList, error)

ListResourceEvents returns a list of event resources 

func (s *Server) ListResourceLinks(ctx context.Context, req *application.ApplicationResourceRequest) (*application.LinksResponse, error)

func (*Server) ManagedResources 

func (s *Server) ManagedResources(ctx context.Context, q *application.ResourcesQuery) (*application.ManagedResourcesResponse, error)

func (*Server) Patch 

func (s *Server) Patch(ctx context.Context, q *application.ApplicationPatchRequest) (*v1alpha1.Application, error)

Patch patches an application

func (*Server) PatchResource 

func (s *Server) PatchResource(ctx context.Context, q *application.ApplicationResourcePatchRequest) (*application.ApplicationResourceResponse, error)

PatchResource patches a resource

func (*Server) PodLogs 

func (s *Server) PodLogs(q *application.ApplicationPodLogsQuery, ws application.ApplicationService_PodLogsServer) error

func (*Server) ResourceTree 

func (s *Server) ResourceTree(ctx context.Context, q *application.ResourcesQuery) (*v1alpha1.ApplicationTree, error)

func (*Server) RevisionChartDetails 

func (s *Server) RevisionChartDetails(ctx context.Context, q *application.RevisionMetadataQuery) (*v1alpha1.ChartDetails, error)

RevisionChartDetails returns the helm chart metadata, as fetched from the reposerver

func (*Server) RevisionMetadata 

func (s *Server) RevisionMetadata(ctx context.Context, q *application.RevisionMetadataQuery) (*v1alpha1.RevisionMetadata, error)

func (*Server) Rollback 

func (s *Server) Rollback(ctx context.Context, rollbackReq *application.ApplicationRollbackRequest) (*v1alpha1.Application, error)

func (*Server) RunResourceAction deprecated 

func (s *Server) RunResourceAction(ctx context.Context, q *application.ResourceActionRunRequest) (*application.ApplicationResponse, error)

RunResourceAction runs a resource action on a live resource

Deprecated: use RunResourceActionV2 instead. This version does not support resource action parameters but is maintained for backward compatibility. It will be removed in a future release.

func (*Server) RunResourceActionV2 added in v3.1.0 

func (s *Server) RunResourceActionV2(ctx context.Context, q *application.ResourceActionRunRequestV2) (*application.ApplicationResponse, error)

func (*Server) ServerSideDiff added in v3.2.0 

func (s *Server) ServerSideDiff(ctx context.Context, q *application.ApplicationServerSideDiffQuery) (*application.ApplicationServerSideDiffResponse, error)

ServerSideDiff gets the destination cluster and creates a server-side dry run applier and performs the diff It returns the diff result in the form of a list of ResourceDiffs.

func (*Server) Sync 

func (s *Server) Sync(ctx context.Context, syncReq *application.ApplicationSyncRequest) (*v1alpha1.Application, error)

Sync syncs an application to its target state

func (*Server) TerminateOperation 

func (s *Server) TerminateOperation(ctx context.Context, termOpReq *application.OperationTerminateRequest) (*application.OperationTerminateResponse, error)

func (*Server) Update 

func (s *Server) Update(ctx context.Context, q *application.ApplicationUpdateRequest) (*v1alpha1.Application, error)

Update updates an application

func (*Server) UpdateSpec 

func (s *Server) UpdateSpec(ctx context.Context, q *application.ApplicationUpdateSpecRequest) (*v1alpha1.ApplicationSpec, error)

UpdateSpec updates an application spec and filters out any invalid parameter overrides

func (*Server) Watch 

func (s *Server) Watch(q *application.ApplicationQuery, ws application.ApplicationService_WatchServer) error

func (*Server) WatchResourceTree 

func (s *Server) WatchResourceTree(q *application.ResourcesQuery, ws application.ApplicationService_WatchResourceTreeServer) error

type TerminalCommand 

type TerminalCommand struct {
	Code int
}

TerminalCommand is the struct for websocket commands,For example you need ask client to reconnect

type TerminalMessage 

type TerminalMessage struct {
	Operation string `json:"operation"`
	Data      string `json:"data"`
	Rows      uint16 `json:"rows"`
	Cols      uint16 `json:"cols"`
}

TerminalMessage is the struct for websocket message.

type TerminalOptions 

type TerminalOptions struct {
	DisableAuth bool
	Enf         *rbac.Enforcer
}

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.