Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Broker ¶
type Broker struct { Variant string // kafka or pulsar BrokerConfig messagebroker.BrokerConfig }
Broker Config (Kafka/Pulsar)
type Config ¶
type Config struct { Broker Broker Interfaces struct { API NetworkInterfaces } HTTPClientConfig httpclient.Config SchedulerConfig tasks.Config }
Config for pushconsumer
type NetworkInterfaces ¶
type NetworkInterfaces struct { GrpcServerAddress string HTTPServerAddress string InternalHTTPServerAddress string }
NetworkInterfaces contains all exposed interfaces
type SchedulerConfig ¶
type SchedulerConfig struct {
NodeBindingRefreshTickerMins int
}
SchedulerConfig contains all scheduler config
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service for worker
func NewService ¶
func NewService(workerConfig *Config, registryConfig *registry.Config, cacheConfig *cache.Config) (*Service, error)
NewService creates an instance of new worker
func (*Service) GetErrorChannel ¶
GetErrorChannel returns service error channel
Click to show internal directories.
Click to hide internal directories.