application

package
v2.8.21 Latest Latest
Warning

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

 Go to latest Published: Nov 19, 2024 License: Apache-2.0 Imports: 64 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

This section is empty.

Functions

func NewHandler 

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

NewHandler returns a new terminal handler.

Types

type AppResourceTreeFn 

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

func NewServer 

func NewServer(
	namespace string,
	kubeclientset kubernetes.Interface,
	appclientset appclientset.Interface,
	appLister applisters.ApplicationLister,
	appInformer cache.SharedIndexInformer,
	appBroadcaster Broadcaster,
	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,
) (application.ApplicationServiceServer, AppResourceTreeFn)

NewServer returns a new instance of the Application service

type Broadcaster 

type Broadcaster interface {
	Subscribe(ch chan *appv1.ApplicationWatchEvent, filters ...func(event *appv1.ApplicationWatchEvent) bool) func()
	OnAdd(interface{}, bool)
	OnUpdate(interface{}, interface{})
	OnDelete(interface{})
}

Broadcaster is an interface for broadcasting application informer watch events to multiple subscribers.

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) (*appv1.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) (*appv1.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) 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) (*appv1.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) (*v1.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) (*appv1.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) (*appv1.ApplicationTree, error)

func (*Server) RevisionChartDetails 

func (s *Server) RevisionChartDetails(ctx context.Context, q *application.RevisionMetadataQuery) (*appv1.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) (*appv1.RevisionMetadata, error)

func (*Server) Rollback 

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

func (*Server) RunResourceAction 

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

func (*Server) Sync 

func (s *Server) Sync(ctx context.Context, syncReq *application.ApplicationSyncRequest) (*appv1.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) (*appv1.Application, error)

Update updates an application

func (*Server) UpdateSpec 

func (s *Server) UpdateSpec(ctx context.Context, q *application.ApplicationUpdateSpecRequest) (*appv1.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

Directories

Path Synopsis

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.