Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultMaxPingsOutstanding int = 3
View Source
var DefaultMaxReconnects int = -1
View Source
var DefaultPingInterval int64 = 10
View Source
var DefaultWorkerCount int = 128
Default settings
Functions ¶
func StrToBytes ¶
Types ¶
type Source ¶
type Source struct {
// contains filtered or unexported fields
}
func (*Source) HandleRequest ¶
func (*Source) InitSubscription ¶
type SourceConfig ¶
type SourceConfig struct {
Sources map[string]SourceInfo `json:"sources"`
}
type SourceInfo ¶
type SourceInfo struct { Host string `json:"host"` Port int `json:"port"` Channel string `json:"channel"` WorkerCount *int `json:"worker_count",omitempty` PingInterval *int64 `json:"ping_interval",omitempty` MaxPingsOutstanding *int `json:"max_pings_outstanding",omitempty` MaxReconnects *int `json:"max_reconnects",omitempty` }
type SourceManager ¶
type SourceManager struct {
// contains filtered or unexported fields
}
func NewSourceManager ¶
func NewSourceManager(adapter *Adapter) *SourceManager
func (*SourceManager) Initialize ¶
func (sm *SourceManager) Initialize() error
func (*SourceManager) LoadSourceConfig ¶
func (sm *SourceManager) LoadSourceConfig(filename string) (*SourceConfig, error)
Click to show internal directories.
Click to hide internal directories.