backend

Documentation

Index

• Constants
• type Broker
• type Message
• type OAuthCredentials
• type Reconciler
  • func NewReconciler(ctx context.Context, natsSubMgr subscriptionmanager.Manager, ...) *Reconciler
  • func (r *Reconciler) CreateOrUpdateBackendCR(ctx context.Context) error
  • func (r *Reconciler) CreateOrUpdatePublisherProxy(ctx context.Context, backend eventingv1alpha1.BackendType) (*appsv1.Deployment, error)
  • func (r *Reconciler) CreateOrUpdatePublisherProxyDeployment(ctx context.Context, backend eventingv1alpha1.BackendType, ...) (*appsv1.Deployment, error)
  • func (r *Reconciler) Reconcile(ctx context.Context, _ ctrl.Request) (ctrl.Result, error)
  • func (r *Reconciler) SetBackendConfig(backendCfg env.BackendConfig)
  • func (r *Reconciler) SetNatsConfig(natsConfig env.NATSConfig)
  • func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *Reconciler) SyncPublisherProxySecret(ctx context.Context, secret *v1.Secret) (*v1.Secret, error)

Constants

const (
	BEBBackendSecretLabelKey   = "kyma-project.io/eventing-backend"
	BEBBackendSecretLabelValue = "beb"

	BEBSecretNameSuffix = "-beb-oauth2"

	BackendCRLabelKey   = "kyma-project.io/eventing"
	BackendCRLabelValue = "backend"

	AppLabelValue             = deployment.PublisherName
	PublisherSecretEMSHostKey = "ems-publish-host"

	TokenEndpointFormat             = "%s?grant_type=%s&response_type=token"
	NamespacePrefix                 = "/"
	BEBPublishEndpointForSubscriber = "/sap/ems/v1"
	BEBPublishEndpointForPublisher  = "/sap/ems/v1/events"
)

Types

type Broker

type Broker struct {
	BrokerType string `json:"type,omitempty"`
}

type Message

type Message struct {
	Broker Broker           `json:"broker,omitempty"`
	OA2    OAuthCredentials `json:"oa2,omitempty"`
	URI    string           `json:"uri,omitempty"`
}

type OAuthCredentials

type OAuthCredentials struct {
	ClientID      string `json:"clientid,omitempty"`
	ClientSecret  string `json:"clientsecret,omitempty"`
	GrantType     string `json:"granttype,omitempty"`
	TokenEndpoint string `json:"tokenendpoint,omitempty"`
}

type Reconciler

type Reconciler struct {
	client.Client
	// contains filtered or unexported fields
}

func NewReconciler

func NewReconciler(
	ctx context.Context,
	natsSubMgr subscriptionmanager.Manager,
	natsConfig env.NATSConfig,
	envCfg env.Config,
	backendCfg env.BackendConfig,
	bebSubMgr subscriptionmanager.Manager,
	client client.Client,
	logger *logger.Logger,
	recorder record.EventRecorder) *Reconciler

func (*Reconciler) CreateOrUpdateBackendCR

func (r *Reconciler) CreateOrUpdateBackendCR(ctx context.Context) error

func (*Reconciler) CreateOrUpdatePublisherProxy

func (r *Reconciler) CreateOrUpdatePublisherProxy(ctx context.Context, backend eventingv1alpha1.BackendType) (*appsv1.Deployment, error)

func (*Reconciler) CreateOrUpdatePublisherProxyDeployment

func (r *Reconciler) CreateOrUpdatePublisherProxyDeployment(
	ctx context.Context,
	backend eventingv1alpha1.BackendType,
	setOwnerReference bool) (*appsv1.Deployment, error)

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, _ ctrl.Request) (ctrl.Result, error)

func (*Reconciler) SetBackendConfig

func (r *Reconciler) SetBackendConfig(backendCfg env.BackendConfig)

func (*Reconciler) SetNatsConfig

func (r *Reconciler) SetNatsConfig(natsConfig env.NATSConfig)

func (*Reconciler) SetupWithManager

func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error

func (*Reconciler) SyncPublisherProxySecret

func (r *Reconciler) SyncPublisherProxySecret(ctx context.Context, secret *v1.Secret) (*v1.Secret, error)