worker

type Broker struct {
	Variant      string // kafka or pulsar
	BrokerConfig messagebroker.BrokerConfig
}

type Config struct {
	Broker     Broker
	Interfaces struct {
		API NetworkInterfaces
	}
	HTTPClientConfig httpclient.Config
	SchedulerConfig  tasks.Config
}

type NetworkInterfaces struct {
	GrpcServerAddress         string
	HTTPServerAddress         string
	InternalHTTPServerAddress string
}

type SchedulerConfig struct {
	NodeBindingRefreshTickerMins int
}

type Service struct {
	// contains filtered or unexported fields
}