eventmesh

Documentation

Index

• Variables
• func AddToScheme(scheme *runtime.Scheme) error
• func AddV1Alpha2ToScheme(scheme *runtime.Scheme) error
• type SubscriptionManager
  • func NewSubscriptionManager(restCfg *rest.Config, metricsAddr string, resyncPeriod time.Duration, ...) *SubscriptionManager
  • func (c *SubscriptionManager) Init(mgr manager.Manager) error
  • func (c *SubscriptionManager) Start(_ env.DefaultSubscriptionConfig, params submgrmanager.Params) error
  • func (c *SubscriptionManager) Stop(runCleanup bool) error

Variables

var (
	ErrDecodingOauthCredentialFailed = errors.New("in")
	ErrDomainEmpty                   = errors.New("domain must be a non-empty value")
)

Functions

func AddToScheme

func AddToScheme(scheme *runtime.Scheme) error

AddToScheme adds the own schemes to the runtime scheme.

func AddV1Alpha2ToScheme

func AddV1Alpha2ToScheme(scheme *runtime.Scheme) error

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.