Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StrToBytes ¶
Types ¶
type Source ¶
type Source struct {
// contains filtered or unexported fields
}
func (*Source) HandleMessage ¶
func (source *Source) HandleMessage(m *stan.Msg)
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"` ClusterID string `json:"cluster_id"` DurableName string `json:"durable_name"` Channel string `json:"channel"` PingInterval int64 `json:"ping_interval"` MaxPingsOutstanding int `json:"max_pings_outstanding"` MaxReconnects int `json:"max_reconnects"` }
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.