httpproxy

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

type HttpProxyCreateFunc func(p ILocalProxy) HttpProxyModule

type HttpProxyModule interface {
	ProxyHandler(addr string, w http.ResponseWriter, r *http.Request)
	Stop()
	GetProxyName() string
}

type ILocalProxy interface {
	GetProxy(pid, protocol, remote, initData string) (string, error)
}

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

type NsqLookupHttpProxy struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Producer struct {
	RemoteAddress    string `json:"remote_address"`
	Hostname         string `json:"hostname"`
	BroadcastAddress string `json:"broadcast_address"`
	TCPPort          int    `json:"tcp_port"`
	HTTPPort         int    `json:"http_port"`
	Version          string `json:"version"`
}