adapter

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

type Packet struct {
	EventName string
	Payload   []byte
}

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

type SourceConfig struct {
	Sources map[string]SourceInfo `json:"sources"`
}

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 struct {
	// contains filtered or unexported fields
}