tablemgr

type DefaultRoutingTableManager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type LiveRouteWrapper struct {
	sync.Mutex
	Route       *route.Route
	Sender      sender.Sender
	Receiver    receiver.Receiver
	FilterChain *filter.Chain
	Config      route.Config
	RefCnt      int
}

type RoutingTableGlobalSyncer interface {
	// StartGlobalSyncChecker
	StartGlobalSyncChecker()
	// RegisterAllRoutes
	RegisterAllRoutes() error
	// UnregisterAllRoutes
	UnregisterAllRoutes() error
	// SynchronizeAllRoutes
	SynchronizeAllRoutes() (int, error)
	// IsSynchronized
	IsSynchronized() (bool, error)
	// GetAllRegisteredRoutes gets all routes that are currently registered and running on ears instance
	GetAllRegisteredRoutes() ([]route.Config, error)
}

type RoutingTableManager interface {
	RoutingTableGlobalSyncer // routing table manager delegates to routing table global syncer for startup and tear down
	syncer.LocalSyncer       // to sync routing table upon receipt of an update notification for a single route
	// AddRoute adds a route to live routing table and runs it and also stores the route in the persistence layer
	AddRoute(ctx context.Context, route *route.Config) error
	// RemoveRoute removes a route from a live routing table and stops it and also removes the route from the persistence layer
	RemoveRoute(ctx context.Context, tenantId tenant.Id, routeId string) error
	// GetRoute gets a single route by its ID from persistence layer
	GetRoute(ctx context.Context, tenantId tenant.Id, routeId string) (*route.Config, error)
	// GetAllTenantRoutes gets all routes for a tenant from persistence layer
	GetAllTenantRoutes(ctx context.Context, tenantId tenant.Id) ([]route.Config, error)
	// GetAllRoutes gets all routes from persistence layer
	GetAllRoutes(ctx context.Context) ([]route.Config, error)
	// GetAllSenders gets all senders currently present in the system
	GetAllSenders(ctx context.Context) (map[string]sender.Sender, error)
	// GetAllReceivers gets all receivers currently present in the system
	GetAllReceivers(ctx context.Context) (map[string]receiver.Receiver, error)
	// GetAllFilters gets all filters currently present in the system
	GetAllFilters(ctx context.Context) (map[string]filter.Filterer, error)
}