server

Documentation

Index

• Variables
• type ArgoCDServer
  • func NewServer(ctx context.Context, opts ArgoCDServerOpts) *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 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 ArgoCDServer

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

ArgoCDServer is the API server for Argo CD

func NewServer

func NewServer(ctx context.Context, opts ArgoCDServerOpts) *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
	EnableGZip            bool
	Insecure              bool
	StaticAssetsDir       string
	ListenPort            int
	ListenHost            string
	MetricsPort           int
	MetricsHost           string
	Namespace             string
	DexServerAddr         string
	DexTLSConfig          *dex.DexTLSConfig
	BaseHRef              string
	RootPath              string
	KubeClientset         kubernetes.Interface
	AppClientset          appclientset.Interface
	RepoClientset         repoapiclient.Clientset
	Cache                 *servercache.Cache
	RedisClient           *redis.Client
	TLSConfigCustomizer   tlsutil.ConfigCustomizer
	XFrameOptions         string
	ContentSecurityPolicy string
	ApplicationNamespaces []string
	EnableProxyExtension  bool
}

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 Listeners

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

func (*Listeners) Close

func (l *Listeners) Close() error