goku_plugin

type Body interface {
	BodyDataReader
	BodyDatawriter
}

type BodyDataReader interface {

	//Protocol() RequestType
	ContentType() string
	//content-Type = application/x-www-form-urlencoded 或 multipart/form-data，与原生request.Form不同，这里不包括 query 参数
	BodyForm() (url.Values, error)
	//content-Type = multipart/form-data 时有效
	Files() (map[string]*FileHeader, error)
	GetForm(key string) string
	GetFile(key string) (file *FileHeader, has bool)
	RawBody() ([]byte, error)
}

type BodyDatawriter interface {
	//设置form数据并将content-type设置 为 application/x-www-form-urlencoded 或 multipart/form-data
	SetForm(values url.Values) error
	SetToForm(key, value string) error
	AddForm(key, value string) error
	// 会替换掉对应掉file信息，并且将content-type 设置为 multipart/form-data
	AddFile(key string, file *FileHeader) error

	// 重置body，会清除掉未处理掉 form和file
	SetRaw(contentType string, body []byte)
}

type BodyGet interface {
	GetBody() []byte
}

type BodySet interface {
	SetBody([]byte)
}

type BoolCmd interface {
	Val() bool
	Result() (bool, error)
	String() string
}

type BoolSliceCmd interface {
	Val() []bool
	Result() ([]bool, error)
	String() string
}

type Cmd interface {
	Val() interface{}
	Result() (interface{}, error)
	String() string
	Int() (int, error)
	Int64() (int64, error)
	Uint64() (uint64, error)
	//Float32() (float32, error)
	Float64() (float64, error)
	Bool() (bool, error)
}

type CmdAble interface {
	Ping() StatusCmd

	Del(keys ...string) IntCmd
	Unlink(keys ...string) IntCmd
	Dump(key string) StringCmd
	Exists(keys ...string) IntCmd
	Expire(key string, expiration time.Duration) BoolCmd
	ExpireAt(key string, tm time.Time) BoolCmd
	Keys(pattern string) StringSliceCmd

	RandomKey() StringCmd
	Rename(key, newkey string) StatusCmd
	RenameNX(key, newkey string) BoolCmd
	Restore(key string, ttl time.Duration, value string) StatusCmd
	RestoreReplace(key string, ttl time.Duration, value string) StatusCmd

	Append(key, value string) IntCmd
	//BitCountS(key string, Start, End int64) IntCmd
	BitOpAnd(destKey string, keys ...string) IntCmd
	BitOpOr(destKey string, keys ...string) IntCmd
	BitOpXor(destKey string, keys ...string) IntCmd
	BitOpNot(destKey string, key string) IntCmd
	BitPos(key string, bit int64, pos ...int64) IntCmd

	Decr(key string) IntCmd
	DecrBy(key string, decrement int64) IntCmd
	Get(key string) StringCmd
	GetBit(key string, offset int64) IntCmd
	GetRange(key string, start, end int64) StringCmd
	GetSet(key string, value interface{}) StringCmd
	Incr(key string) IntCmd
	IncrBy(key string, value int64) IntCmd
	IncrByFloat(key string, value float64) FloatCmd
	MGet(keys ...string) SliceCmd
	MSet(pairs ...interface{}) StatusCmd
	MSetNX(pairs ...interface{}) BoolCmd
	Set(key string, value interface{}, expiration time.Duration) StatusCmd
	SetBit(key string, offset int64, value int) IntCmd
	SetNX(key string, value interface{}, expiration time.Duration) BoolCmd
	SetXX(key string, value interface{}, expiration time.Duration) BoolCmd
	SetRange(key string, offset int64, value string) IntCmd
	StrLen(key string) IntCmd
	HDel(key string, fields ...string) IntCmd
	HExists(key, field string) BoolCmd
	HGet(key, field string) StringCmd
	HGetAll(key string) StringStringMapCmd
	HIncrBy(key, field string, incr int64) IntCmd
	HIncrByFloat(key, field string, incr float64) FloatCmd
	HKeys(key string) StringSliceCmd
	HLen(key string) IntCmd
	HMGet(key string, fields ...string) SliceCmd
	HMSet(key string, fields map[string]interface{}) BoolCmd
	HSet(key, field string, value interface{}) IntCmd
	HSetNX(key, field string, value interface{}) BoolCmd
	HVals(key string) StringSliceCmd
	BLPop(timeout time.Duration, keys ...string) StringSliceCmd
	BRPop(timeout time.Duration, keys ...string) StringSliceCmd
	BRPopLPush(source, destination string, timeout time.Duration) StringCmd
	LIndex(key string, index int64) StringCmd
	LInsert(key, op string, pivot, value interface{}) IntCmd
	LInsertBefore(key string, pivot, value interface{}) IntCmd
	LInsertAfter(key string, pivot, value interface{}) IntCmd
	LLen(key string) IntCmd
	LPop(key string) StringCmd
	LPush(key string, values ...interface{}) IntCmd
	LPushX(key string, value interface{}) IntCmd
	LRange(key string, start, stop int64) StringSliceCmd
	LRem(key string, count int64, value interface{}) IntCmd
	LSet(key string, index int64, value interface{}) StatusCmd
	LTrim(key string, start, stop int64) StatusCmd
	RPop(key string) StringCmd
	RPopLPush(source, destination string) StringCmd
	RPush(key string, values ...interface{}) IntCmd
	RPushX(key string, value interface{}) IntCmd
	SAdd(key string, members ...interface{}) IntCmd
	SCard(key string) IntCmd
	SDiff(keys ...string) StringSliceCmd
	SDiffStore(destination string, keys ...string) IntCmd
	SInter(keys ...string) StringSliceCmd
	SInterStore(destination string, keys ...string) IntCmd
	SIsMember(key string, member interface{}) BoolCmd
	SMembers(key string) StringSliceCmd
	SMembersMap(key string) StringStructMapCmd
	SMove(source, destination string, member interface{}) BoolCmd
	SPop(key string) StringCmd
	SPopN(key string, count int64) StringSliceCmd
	SRandMember(key string) StringCmd
	SRandMemberN(key string, count int64) StringSliceCmd
	SRem(key string, members ...interface{}) IntCmd
	SUnion(keys ...string) StringSliceCmd
	SUnionStore(destination string, keys ...string) IntCmd
}

type Cmder interface {
	Name() string
	Args() []interface{}

	Err() error
}

type Context interface {
	ResponseWriter // 处理返回
	StoreContainer // cache
	RequestId() string
	FinalTargetServer() string
	RetryTargetServers() string
}

type ContextAccess interface {
	Context        // 处理返回
	ContextApiInfo // api 信息
	Request() RequestReader
	Proxy() Request // 请求信息，包含原始请求数据以及被更高优先级处理过的结果
}

type ContextApiInfo interface {
	//ServiceId() string
	//Service()string
	//Version()string
	//Name()string
	StrategyId() string
	StrategyName() string
	ApiID() int
}

type ContextBeforeMatch interface {
	Context // 处理返回
	Request() RequestReader
	Proxy() Request // 请求信息，包含原始请求数据以及被更高优先级处理过的结果
}

type ContextProxy interface {
	Context                        // 处理返回
	ContextApiInfo                 // api 信息
	ProxyResponse() ResponseReader // 转发后返回的结果
}

type CookieReader interface {
	Cookie(name string) (*http.Cookie, error)
	Cookies() []*http.Cookie
}

type CookieWriter interface {
	AddCookie(c *http.Cookie)
}

type DurationCmd interface {
	Val() time.Duration
	Result() (time.Duration, error)
	String() string
}

type FileHeader struct {
	FileName string
	Header   textproto.MIMEHeader
	Data     []byte
}

type FloatCmd interface {
	Val() float64
	Result() (float64, error)
	String() string
}

type Header interface {
	HeaderReader
	HeaderWriter
}

type HeaderReader interface {
	GetHeader(name string) string
	// 返回所有header，返回值为一个副本，对他的修改不会生效
	Headers() http.Header
}

type HeaderWriter interface {
	SetHeader(key, value string)
	AddHeader(key, value string)
	DelHeader(key string)
}

type IntCmd interface {
	Val() int64
	Result() (int64, error)
	String() string
}

type Logger interface {
	Debugf(format string, args ...interface{})
	Infof(format string, args ...interface{})

	Warnf(format string, args ...interface{})
	Warningf(format string, args ...interface{})
	Errorf(format string, args ...interface{})

	Debug(args ...interface{})
	Info(args ...interface{})

	Warn(args ...interface{})
	Warning(args ...interface{})
	Error(args ...interface{})
}

type Pipeliner interface {
	StatefulCmdable
	Do(args ...interface{}) Cmd
	//Process(cmd Cmder) error
	Close() error
	Discard() error
	Exec() ([]Cmder, error)
}

type PluginAccess interface {
	Access(ctx ContextAccess) (isContinue bool, e error)
}

type PluginBeforeMatch interface {
	BeforeMatch(ctx ContextBeforeMatch) (isContinue bool, e error)
}

type PluginFactory interface {
	Create(config string, clusterName string, updateTag string, service string, apiId int) (*PluginObj, error)
}

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

type PluginObj struct {
	BeforeMatch PluginBeforeMatch
	Access      PluginAccess
	Proxy       PluginProxy
}

type PluginProxy interface {
	Proxy(ctx ContextProxy) (isContinue bool, e error)
}

type PriorityHeader interface {
	HeaderReader // 读已经设置的header
	HeaderWriter // 设置header
	// 非Priority的header会被 proxy 的同名项替换掉，
	Set() Header    // 这里设置的header会替换掉proxy的内容
	Append() Header // 这里设置的header会追加到proxy的内容
}

type Redis interface {
	CmdAble
	Pipeline() Pipeliner
	Pipelined(fn func(Pipeliner) error) ([]Cmder, error)
}

type RedisManager interface {
	Default() Redis
	Get(name string) (redis Redis, has bool)
}

type Request interface {
	CookieReader
	HeaderReader
	HeaderWriter
	CookieWriter
	Body
	Querys() url.Values
	TargetServer() string
	TargetURL() string
}

type RequestData interface {
	BodyDataReader
	Method() string
	URL() *url.URL
	RequestURI() string
	Host() string
	RemoteAddr() string
	Proto() string
}

type RequestReader interface {
	CookieReader
	HeaderReader
	RequestData
}

type ResponseReader interface {
	CookieReader
	HeaderReader
	BodyGet
	StatusGet
}

type ResponseWriter interface {
	PriorityHeader
	CookieReader // 已经设置的cookie
	CookieWriter // 设置返回的cookie
	StatusGet
	StatusSet // 设置返回状态
	BodySet   // 设置返回内容
	BodyGet
}

type SliceCmd interface {
	Val() []interface{}
	Result() ([]interface{}, error)
	String() string
}

type StatefulCmdable interface {
	CmdAble
	Auth(password string) StatusCmd
	Select(index int) StatusCmd
	SwapDB(index1, index2 int) StatusCmd
	ClientSetName(name string) BoolCmd
}

type StatusCmd interface {
	Val() string
	Result() (string, error)
	String() string
}

type StatusGet interface {
	StatusCode() int
	Status() string
}

type StatusSet interface {
	SetStatus(code int, status string)
}

type Store interface {
	Set(value interface{})
	Get() (value interface{})
}

type StoreContainer interface {
	Store() Store // 私有存储
	SetCache(name string, value interface{})
	GetCache(name string) (value interface{}, has bool)
}

type StringCmd interface {
	Val() string
	Result() (string, error)
	Bytes() ([]byte, error)
	Int() (int, error)
	Int64() (int64, error)
	Uint64() (uint64, error)
	//Float32() (float32, error)
	Float64() (float64, error)
	Scan(val interface{}) error
	String() string
}

type StringIntMapCmd interface {
	Val() map[string]int64
	Result() (map[string]int64, error)
	String() string
}

type StringSliceCmd interface {
	Val() []string
	Result() ([]string, error)
	String() string
	ScanSlice(container interface{}) error
}

type StringStringMapCmd interface {
	Val() map[string]string
	Result() (map[string]string, error)
	String() string
}

type StringStructMapCmd interface {
	Val() map[string]struct{}
	Result() (map[string]struct{}, error)
	String() string
}

type TimeCmd interface {
	Val() time.Time
	Result() (time.Time, error)
	String() string
}