Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrDecodingOauthCredentialFailed = errors.New("in") ErrDomainEmpty = errors.New("domain must be a non-empty value") )
Functions ¶
func AddToScheme ¶
AddToScheme adds the own schemes to the runtime scheme.
func AddV1Alpha2ToScheme ¶
AddV1Alpha2ToScheme adds v1alpha2 scheme into the given scheme.
Types ¶
type SubscriptionManager ¶
type SubscriptionManager struct {
// contains filtered or unexported fields
}
SubscriptionManager implements the subscriptionmanager.Manager interface.
func NewSubscriptionManager ¶
func NewSubscriptionManager(restCfg *rest.Config, metricsAddr string, resyncPeriod time.Duration, logger *logger.Logger, collector *metrics.Collector, domain string, ) *SubscriptionManager
NewSubscriptionManager creates the SubscriptionManager for BEB and initializes it as far as it does not depend on non-common options.
func (*SubscriptionManager) Init ¶
func (c *SubscriptionManager) Init(mgr manager.Manager) error
Init implements the subscriptionmanager.Manager interface.
func (*SubscriptionManager) Start ¶
func (c *SubscriptionManager) Start(_ env.DefaultSubscriptionConfig, params submgrmanager.Params) error
Start implements the subscriptionmanager.Manager interface and starts the manager.
func (*SubscriptionManager) Stop ¶
func (c *SubscriptionManager) Stop(runCleanup bool) error
Stop implements the subscriptionmanager.Manager interface and stops the EventMesh subscription manager. If runCleanup is false, it will only mark the subscriptions as not ready. If it is true, it will clean up subscriptions on EventMesh.
Source Files
Click to show internal directories.
Click to hide internal directories.