server

Documentation

Index

• Variables
• type ApplicationSetOpts
• type ArgoCDServer
  • func NewServer(ctx context.Context, opts ArgoCDServerOpts, appsetOpts ApplicationSetOpts) *ArgoCDServer
  • func (a *ArgoCDServer) Authenticate(ctx context.Context) (context.Context, error)
  • func (a *ArgoCDServer) Init(ctx context.Context)
  • func (a *ArgoCDServer) Initialized() bool
  • func (a *ArgoCDServer) Listen() (*Listeners, error)
  • func (a *ArgoCDServer) Run(ctx context.Context, listeners *Listeners)
  • func (a *ArgoCDServer) Shutdown()
• type ArgoCDServerOpts
• type ArgoCDServiceSet
• type HTTPMetricsRegistry
• type Listeners
  • func (l *Listeners) Close() error

Variables

var ErrNoSession = status.Errorf(codes.Unauthenticated, "no session information")

ErrNoSession indicates no auth token was supplied as part of a request

Types

type ApplicationSetOpts

type ApplicationSetOpts struct {
	GitSubmoduleEnabled      bool
	EnableNewGitFileGlobbing bool
	ScmRootCAPath            string
	AllowedScmProviders      []string
	EnableScmProviders       bool
}

type ArgoCDServer

type ArgoCDServer struct {
	ArgoCDServerOpts
	ApplicationSetOpts
	// contains filtered or unexported fields
}

ArgoCDServer is the API server for Argo CD

func NewServer

func NewServer(ctx context.Context, opts ArgoCDServerOpts, appsetOpts ApplicationSetOpts) *ArgoCDServer

NewServer returns a new instance of the Argo CD API server

func (*ArgoCDServer) Authenticate

func (a *ArgoCDServer) Authenticate(ctx context.Context) (context.Context, error)

Authenticate checks for the presence of a valid token when accessing server-side resources.

func (*ArgoCDServer) Init

func (a *ArgoCDServer) Init(ctx context.Context)

Init starts informers used by the API server

func (*ArgoCDServer) Initialized

func (a *ArgoCDServer) Initialized() bool

func (*ArgoCDServer) Listen

func (a *ArgoCDServer) Listen() (*Listeners, error)

func (*ArgoCDServer) Run

func (a *ArgoCDServer) Run(ctx context.Context, listeners *Listeners)

Run runs the API Server We use k8s.io/code-generator/cmd/go-to-protobuf to generate the .proto files from the API types. k8s.io/ go-to-protobuf uses protoc-gen-gogo, which comes from gogo/protobuf (a fork of golang/protobuf).

func (*ArgoCDServer) Shutdown

func (a *ArgoCDServer) Shutdown()

Shutdown stops the Argo CD server

type ArgoCDServerOpts

type ArgoCDServerOpts struct {
	DisableAuth             bool
	ContentTypes            []string
	EnableGZip              bool
	Insecure                bool
	StaticAssetsDir         string
	ListenPort              int
	ListenHost              string
	MetricsPort             int
	MetricsHost             string
	Namespace               string
	DexServerAddr           string
	DexTLSConfig            *dexutil.DexTLSConfig
	BaseHRef                string
	RootPath                string
	DynamicClientset        dynamic.Interface
	KubeControllerClientset client.Client
	KubeClientset           kubernetes.Interface
	AppClientset            appclientset.Interface
	RepoClientset           repoapiclient.Clientset
	Cache                   *servercache.Cache
	RepoServerCache         *repocache.Cache
	RedisClient             *redis.Client
	TLSConfigCustomizer     tlsutil.ConfigCustomizer
	XFrameOptions           string
	ContentSecurityPolicy   string
	ApplicationNamespaces   []string
	EnableProxyExtension    bool
	WebhookParallelism      int
	EnableK8sEvent          []string
}

type ArgoCDServiceSet

type ArgoCDServiceSet struct {
	ClusterService        *cluster.Server
	RepoService           *repository.Server
	RepoCredsService      *repocreds.Server
	SessionService        *session.Server
	ApplicationService    applicationpkg.ApplicationServiceServer
	AppResourceTreeFn     application.AppResourceTreeFn
	ApplicationSetService applicationsetpkg.ApplicationSetServiceServer
	ProjectService        *project.Server
	SettingsService       *settings.Server
	AccountService        *account.Server
	NotificationService   notificationpkg.NotificationServiceServer
	CertificateService    *certificate.Server
	GpgkeyService         *gpgkey.Server
	VersionService        *version.Server
}

type HTTPMetricsRegistry

type HTTPMetricsRegistry interface {
	// IncExtensionRequestCounter will increase the request counter for the given
	// extension with the given status.
	IncExtensionRequestCounter(extension string, status int)
	// ObserveExtensionRequestDuration will register the request roundtrip duration
	// between Argo CD API Server and the extension backend service for the given
	// extension.
	ObserveExtensionRequestDuration(extension string, duration time.Duration)
}

HTTPMetricsRegistry exposes operations to update http metrics in the Argo CD API server.

type Listeners

type Listeners struct {
	Main        net.Listener
	Metrics     net.Listener
	GatewayConn *grpc.ClientConn
}

func (*Listeners) Close

func (l *Listeners) Close() error