gateway

var (
	ResponseOk = []byte(`{"ok":1}`)

	HttpHeaderAppid  = "Appid"
	HttpHeaderPubkey = "Pubkey"
	HttpHeaderSubkey = "Subkey"
)

var (
	ErrClientGone           = errors.New("remote client gone")
	ErrTooBigMessage        = errors.New("too big message")
	ErrTooSmallMessage      = errors.New("too small message")
	ErrIllegalTaggedMessage = errors.New("illegal tagged message")
	ErrClientKilled         = errors.New("client killed")
	ErrBadResponseWriter    = errors.New("ResponseWriter Close not supported")
	ErrPartitionOutOfRange  = errors.New("partition out of range")
	ErrOffsetOutOfRange     = errors.New("offset out of range")
)

var (
	Options struct {
		Id                         string
		Zone                       string
		ConfigFile                 string
		PubHttpAddr                string
		PubHttpsAddr               string
		SubHttpAddr                string
		SubHttpsAddr               string
		ManHttpAddr                string
		ManHttpsAddr               string
		DebugHttpAddr              string
		Store                      string
		JobStore                   string
		ManagerStore               string
		PidFile                    string
		CertFile                   string
		KeyFile                    string
		LogFile                    string
		LogLevel                   string
		CrashLogFile               string
		DummyCluster               string
		InfluxServer               string
		InfluxDbName               string
		KillFile                   string
		HintedHandoffType          string
		HintedHandoffDir           string
		AllwaysHintedHandoff       bool
		ShowVersion                bool
		Ratelimit                  bool
		PermitStandbySub           bool
		DisableMetrics             bool
		EnableHintedHandoff        bool
		HintedHandoffBufio         bool
		FlushHintedOffOnly         bool
		BadGroupRateLimit          bool
		BadPubAppRateLimit         bool
		RunSwaggerServer           bool
		AuditPub                   bool
		AuditSub                   bool
		EnableGzip                 bool
		DryRun                     bool
		CpuAffinity                bool
		EnableAccessLog            bool
		EnableHttpPanicRecover     bool
		GolangTrace                bool
		PermitUnregisteredGroup    bool
		UseCompress                bool
		Debug                      bool
		EnableRegistry             bool
		HttpHeaderMaxBytes         int
		MaxPubSize                 int64
		MaxJobSize                 int64
		LogRotateSize              int
		MaxMsgTagLen               int
		MinPubSize                 int
		PubQpsLimit                int64
		MaxSubBatchSize            int
		MaxClients                 int
		MaxRequestPerConn          int // to make load balancer distribute request even for persistent conn
		PubPoolCapcity             int
		AssignJobShardId           int // how to assign shard id for new app
		PubPoolIdleTimeout         time.Duration
		SubTimeout                 time.Duration
		OffsetCommitInterval       time.Duration
		BadClientPunishDuration    time.Duration
		InternalServerErrorBackoff time.Duration
		ReporterInterval           time.Duration
		MetaRefresh                time.Duration
		ManagerRefresh             time.Duration
		HttpReadTimeout            time.Duration
		HttpWriteTimeout           time.Duration
		MaxWaitBeforeForceClose    time.Duration
	}
)