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