remoteenvironment

Documentation

Index

• func NewRemoteEnvironmentResolver(reSvc reSvc, statusGetter statusGetter) *remoteEnvironmentResolver
• type AsyncApiSpecGetter
• type Config
• type ConnectorSvcCfg
• type Container
  • func New(restConfig *rest.Config, reCfg Config, informerResyncPeriod time.Duration, ...) (*Container, error)
• type RemoteEnvironmentLister
• type Resolver
  • func (r Resolver) ConnectorServiceQuery(ctx context.Context, remoteEnvironment string) (gqlschema.ConnectorService, error)
  • func (r Resolver) DisableRemoteEnvironmentMutation(ctx context.Context, remoteEnvironment string, environment string) (*gqlschema.EnvironmentMapping, error)
  • func (r Resolver) EnableRemoteEnvironmentMutation(ctx context.Context, remoteEnvironment string, environment string) (*gqlschema.EnvironmentMapping, error)
  • func (r Resolver) EventActivationEventsField(ctx context.Context, eventActivation *gqlschema.EventActivation) ([]gqlschema.EventActivationEvent, error)
  • func (r Resolver) EventActivationsQuery(ctx context.Context, environment string) ([]gqlschema.EventActivation, error)
  • func (r Resolver) RemoteEnvironmentEnabledInEnvironmentsField(ctx context.Context, obj *gqlschema.RemoteEnvironment) ([]string, error)
  • func (r Resolver) RemoteEnvironmentQuery(ctx context.Context, name string) (*gqlschema.RemoteEnvironment, error)
  • func (r Resolver) RemoteEnvironmentStatusField(ctx context.Context, re *gqlschema.RemoteEnvironment) (gqlschema.RemoteEnvironmentStatus, error)
  • func (r Resolver) RemoteEnvironmentsQuery(ctx context.Context, environment *string, first *int, offset *int) ([]gqlschema.RemoteEnvironment, error)
  • func (r *Resolver) WaitForCacheSync(stopCh <-chan struct{})

Functions

func NewRemoteEnvironmentResolver

func NewRemoteEnvironmentResolver(reSvc reSvc, statusGetter statusGetter) *remoteEnvironmentResolver

Types

type AsyncApiSpecGetter

type AsyncApiSpecGetter interface {
	Find(kind, id string) (*storage.AsyncApiSpec, error)
}

type Config

type Config struct {
	Gateway   gateway.Config
	Connector ConnectorSvcCfg
}

type ConnectorSvcCfg

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

type Container

type Container struct {
	Resolver *Resolver
	RELister RemoteEnvironmentLister
}

func New

func New(restConfig *rest.Config, reCfg Config, informerResyncPeriod time.Duration, asyncApiSpecGetter AsyncApiSpecGetter) (*Container, error)

type RemoteEnvironmentLister

type RemoteEnvironmentLister interface {
	ListInEnvironment(environment string) ([]*v1alpha1.RemoteEnvironment, error)
	ListNamespacesFor(reName string) ([]string, error)
}

type Resolver

type Resolver struct {
	// contains filtered or unexported fields
}

func (Resolver) ConnectorServiceQuery

func (r Resolver) ConnectorServiceQuery(ctx context.Context, remoteEnvironment string) (gqlschema.ConnectorService, error)

func (Resolver) DisableRemoteEnvironmentMutation

func (r Resolver) DisableRemoteEnvironmentMutation(ctx context.Context, remoteEnvironment string, environment string) (*gqlschema.EnvironmentMapping, error)

func (Resolver) EnableRemoteEnvironmentMutation

func (r Resolver) EnableRemoteEnvironmentMutation(ctx context.Context, remoteEnvironment string, environment string) (*gqlschema.EnvironmentMapping, error)

func (Resolver) EventActivationEventsField

func (r Resolver) EventActivationEventsField(ctx context.Context, eventActivation *gqlschema.EventActivation) ([]gqlschema.EventActivationEvent, error)

func (Resolver) EventActivationsQuery

func (r Resolver) EventActivationsQuery(ctx context.Context, environment string) ([]gqlschema.EventActivation, error)

func (Resolver) RemoteEnvironmentEnabledInEnvironmentsField

func (r Resolver) RemoteEnvironmentEnabledInEnvironmentsField(ctx context.Context, obj *gqlschema.RemoteEnvironment) ([]string, error)

func (Resolver) RemoteEnvironmentQuery

func (r Resolver) RemoteEnvironmentQuery(ctx context.Context, name string) (*gqlschema.RemoteEnvironment, error)

func (Resolver) RemoteEnvironmentStatusField

func (r Resolver) RemoteEnvironmentStatusField(ctx context.Context, re *gqlschema.RemoteEnvironment) (gqlschema.RemoteEnvironmentStatus, error)

func (Resolver) RemoteEnvironmentsQuery

func (r Resolver) RemoteEnvironmentsQuery(ctx context.Context, environment *string, first *int, offset *int) ([]gqlschema.RemoteEnvironment, error)

func (*Resolver) WaitForCacheSync

func (r *Resolver) WaitForCacheSync(stopCh <-chan struct{})