Documentation
¶
Index ¶
- Constants
- Variables
- func CheckIfTopicExists(ctx context.Context, topic string) bool
- func UpdateTopicCache(ctx context.Context, topicMap map[string]bool, specificTopicBool bool)
- type Config
- type ITask
- func NewLeaderTask(id string, registry registry.IRegistry, nodeCore node.ICore, task ITask, ...) (ITask, error)
- func NewPublisherTask(id string, registry registry.IRegistry, topicCore topic.ICore, ...) (ITask, error)
- func NewSchedulerTask(id string, registry registry.IRegistry, brokerStore brokerstore.IBrokerStore, ...) (ITask, error)
- func NewSubscriptionTask(id string, reg registry.IRegistry, brokerStore brokerstore.IBrokerStore, ...) (ITask, error)
- type LeaderTask
- type Option
- type PublisherTask
- type SchedulerTask
- type SubscriptionTask
Constants ¶
const (
// LeaderKey is the path for which nodes contest for lock
LeaderKey = "leader/election"
)
Variables ¶
TopicCacheData is declared Global to keep it instance agnostic
Functions ¶
func CheckIfTopicExists ¶
CheckIfTopicExists is to check if topic exists inside the cache
Types ¶
type ITask ¶
ITask defines worker interface
func NewLeaderTask ¶
func NewLeaderTask( id string, registry registry.IRegistry, nodeCore node.ICore, task ITask, options ...Option, ) (ITask, error)
NewLeaderTask creates LeaderTask instance
func NewPublisherTask ¶
func NewPublisherTask( id string, registry registry.IRegistry, topicCore topic.ICore, options ...Option, ) (ITask, error)
NewPublisherTask creates PublisherTask instance
func NewSchedulerTask ¶
func NewSchedulerTask( id string, registry registry.IRegistry, brokerStore brokerstore.IBrokerStore, nodeCore node.ICore, topicCore topic.ICore, nodeBindingCore nodebinding.ICore, subscriptionCore subscription.ICore, scheduler scheduler.IScheduler, options ...Option, ) (ITask, error)
NewSchedulerTask creates SchedulerTask instance
func NewSubscriptionTask ¶
func NewSubscriptionTask( id string, reg registry.IRegistry, brokerStore brokerstore.IBrokerStore, subscriptionCore subscription.ICore, nodebindingCore nodebinding.ICore, subscriberCore subscriber.ICore, options ...Option, ) (ITask, error)
NewSubscriptionTask creates SubscriptionTask instance
type LeaderTask ¶
type LeaderTask struct {
// contains filtered or unexported fields
}
LeaderTask runs the leader election process and runs the task associated
type Option ¶
type Option func(task ITask)
A Option is an option for tasks
func WithHTTPConfig ¶
func WithHTTPConfig(config *httpclient.Config) Option
WithHTTPConfig defines the httpClient config for wehbooks http client
func WithSchedulerConfig ¶
WithSchedulerConfig defines the scheduler config for automatic node binding refresh
type PublisherTask ¶
type PublisherTask struct {
// contains filtered or unexported fields
}
PublisherTask implements the Watcher and maintains a pre-warmup.
type SchedulerTask ¶
type SchedulerTask struct {
// contains filtered or unexported fields
}
SchedulerTask implements the scheduling of subscriptions over nodes. only leader node elected using the leader election process does scheduling
type SubscriptionTask ¶
type SubscriptionTask struct {
// contains filtered or unexported fields
}
SubscriptionTask runs the assigned subscriptions to the node
Source Files