application

Documentation

Index

• Constants
• func NewHandler(appLister applisters.ApplicationLister, namespace string, ...) *terminalHandler
• type AppResourceTreeFn
  • func NewServer(namespace string, kubeclientset kubernetes.Interface, ...) (application.ApplicationServiceServer, AppResourceTreeFn)
• type GetSettingsFunc
• type PtyHandler
• type Server
  • func (s *Server) Create(ctx context.Context, q *application.ApplicationCreateRequest) (*appv1.Application, error)
  • func (s *Server) Delete(ctx context.Context, q *application.ApplicationDeleteRequest) (*application.ApplicationResponse, error)
  • func (s *Server) DeleteResource(ctx context.Context, q *application.ApplicationResourceDeleteRequest) (*application.ApplicationResponse, error)
  • func (s *Server) Get(ctx context.Context, q *application.ApplicationQuery) (*appv1.Application, error)
  • func (s *Server) GetApplicationSyncWindows(ctx context.Context, q *application.ApplicationSyncWindowsQuery) (*application.ApplicationSyncWindowsResponse, error)
  • func (s *Server) GetManifests(ctx context.Context, q *application.ApplicationManifestQuery) (*apiclient.ManifestResponse, error)
  • func (s *Server) GetManifestsWithFiles(stream application.ApplicationService_GetManifestsWithFilesServer) error
  • func (s *Server) GetResource(ctx context.Context, q *application.ApplicationResourceRequest) (*application.ApplicationResourceResponse, error)
  • func (s *Server) List(ctx context.Context, q *application.ApplicationQuery) (*appv1.ApplicationList, error)
  • func (s *Server) ListResourceActions(ctx context.Context, q *application.ApplicationResourceRequest) (*application.ResourceActionsListResponse, error)
  • func (s *Server) ListResourceEvents(ctx context.Context, q *application.ApplicationResourceEventsQuery) (*v1.EventList, error)
  • func (s *Server) ManagedResources(ctx context.Context, q *application.ResourcesQuery) (*application.ManagedResourcesResponse, error)
  • func (s *Server) Patch(ctx context.Context, q *application.ApplicationPatchRequest) (*appv1.Application, error)
  • func (s *Server) PatchResource(ctx context.Context, q *application.ApplicationResourcePatchRequest) (*application.ApplicationResourceResponse, error)
  • func (s *Server) PodLogs(q *application.ApplicationPodLogsQuery, ...) error
  • func (s *Server) ResourceTree(ctx context.Context, q *application.ResourcesQuery) (*appv1.ApplicationTree, error)
  • func (s *Server) RevisionMetadata(ctx context.Context, q *application.RevisionMetadataQuery) (*v1alpha1.RevisionMetadata, error)
  • func (s *Server) Rollback(ctx context.Context, rollbackReq *application.ApplicationRollbackRequest) (*appv1.Application, error)
  • func (s *Server) RunResourceAction(ctx context.Context, q *application.ResourceActionRunRequest) (*application.ApplicationResponse, error)
  • func (s *Server) Sync(ctx context.Context, syncReq *application.ApplicationSyncRequest) (*appv1.Application, error)
  • func (s *Server) TerminateOperation(ctx context.Context, termOpReq *application.OperationTerminateRequest) (*application.OperationTerminateResponse, error)
  • func (s *Server) Update(ctx context.Context, q *application.ApplicationUpdateRequest) (*appv1.Application, error)
  • func (s *Server) UpdateSpec(ctx context.Context, q *application.ApplicationUpdateSpecRequest) (*appv1.ApplicationSpec, error)
  • func (s *Server) Watch(q *application.ApplicationQuery, ws application.ApplicationService_WatchServer) error
  • func (s *Server) WatchResourceTree(q *application.ResourcesQuery, ...) error
• type TerminalMessage

Constants

const EndOfTransmission = "\u0004"

Functions

func NewHandler

func NewHandler(appLister applisters.ApplicationLister, namespace string, enabledNamespaces []string, db db.ArgoDB, enf *rbac.Enforcer, cache *servercache.Cache,
	appResourceTree AppResourceTreeFn, allowedShells []string) *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,
	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,
) (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) (*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 (*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 (*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) 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) (*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 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.