application

Documentation

Index

• func NewApplicationResolver(appSvc appSvc, statusGetter statusGetter) *applicationResolver
• type ApplicationLister
• type Config
• type ConnectorSvcCfg
• type PluggableContainer
  • func New(restConfig *rest.Config, reCfg Config, informerResyncPeriod time.Duration, ...) (*PluggableContainer, error)
  • func (r *PluggableContainer) Disable() error
  • func (r *PluggableContainer) Enable() error
• type Resolver

Functions

func NewApplicationResolver

func NewApplicationResolver(appSvc appSvc, statusGetter statusGetter) *applicationResolver

Types

type ApplicationLister

type ApplicationLister interface {
	ListInNamespace(namespace string) ([]*v1alpha1.Application, error)
	ListNamespacesFor(appName string) ([]string, error)
}

type Config

type Config struct {
	Gateway   gateway.Config
	Connector ConnectorSvcCfg
}

type ConnectorSvcCfg

type ConnectorSvcCfg struct {
	URL             string        `envconfig:"optional"`
	HTTPCallTimeout time.Duration `envconfig:"default=500ms"`
}

type PluggableContainer

type PluggableContainer struct {
	*module.Pluggable

	Resolver             Resolver
	ApplicationRetriever *applicationRetriever
	// contains filtered or unexported fields
}

func New

func New(restConfig *rest.Config, reCfg Config, informerResyncPeriod time.Duration, rafterRetriever shared.RafterRetriever) (*PluggableContainer, error)

func (*PluggableContainer) Disable

func (r *PluggableContainer) Disable() error

func (*PluggableContainer) Enable

func (r *PluggableContainer) Enable() error

type Resolver

type Resolver interface {
	ApplicationQuery(ctx context.Context, name string) (*gqlschema.Application, error)
	ApplicationsQuery(ctx context.Context, namespace *string, first *int, offset *int) ([]*gqlschema.Application, error)
	ApplicationEventSubscription(ctx context.Context) (<-chan *gqlschema.ApplicationEvent, error)
	CreateApplication(ctx context.Context, name string, description *string, qglLabels gqlschema.Labels) (*gqlschema.ApplicationMutationOutput, error)
	DeleteApplication(ctx context.Context, name string) (*gqlschema.DeleteApplicationOutput, error)
	UpdateApplication(ctx context.Context, name string, description *string, qglLabels gqlschema.Labels) (*gqlschema.ApplicationMutationOutput, error)
	ConnectorServiceQuery(ctx context.Context, application string) (*gqlschema.ConnectorService, error)
	EnableApplicationMutation(ctx context.Context, application string, namespace string, allServices *bool, services []*gqlschema.ApplicationMappingService) (*gqlschema.ApplicationMapping, error)
	OverloadApplicationMutation(ctx context.Context, application string, namespace string, allServices *bool, services []*gqlschema.ApplicationMappingService) (*gqlschema.ApplicationMapping, error)
	DisableApplicationMutation(ctx context.Context, application string, namespace string) (*gqlschema.ApplicationMapping, error)
	ApplicationEnabledInNamespacesField(ctx context.Context, obj *gqlschema.Application) ([]string, error)
	ApplicationEnabledMappingServices(ctx context.Context, obj *gqlschema.Application) ([]*gqlschema.EnabledMappingService, error)
	ApplicationStatusField(ctx context.Context, app *gqlschema.Application) (gqlschema.ApplicationStatus, error)
	EventActivationsQuery(ctx context.Context, namespace string) ([]*gqlschema.EventActivation, error)
	EventActivationEventsField(ctx context.Context, eventActivation *gqlschema.EventActivation) ([]*gqlschema.EventActivationEvent, error)
}