cmd

type App struct {
	Closed    chan struct{}
	Hub       *agg.Hub
	Opts      Specification
	Websocket *rwc.Hub
	WaitGroup sync.WaitGroup
}

type Command struct {
	Verb  string
	What  string
	Which string
	Rule  *json.RawMessage
}

type Packet struct {
	Data []byte
}

type RuleStream struct {
	Stream string
	Feeds  []string
}

type Specification struct {
	Port               int    `default:"8888"`
	LogLevel           string `split_words:"true" default:"TRACE"`
	MuxBufferLength    int    `default:"10"`
	ClientBufferLength int    `default:"5"`
	ClientTimeoutMs    int    `default:"1000"`
	HttpWaitMs         int    `default:"5000"`
	HttpFlushMs        int    `default:"5"`
	HttpTimeoutMs      int    `default:"1000"`
	CpuProfile         string `default:""`
	API                string `default:""`
}

type WsHandlerClient struct {
	Messages   *hub.Client
	Conn       *websocket.Conn
	UserAgent  string //r.UserAgent()
	RemoteAddr string //r.Header.Get("X-Forwarded-For")
}