dbproxy

type CustomRequestActionInterface interface {
	// contains filtered or unexported methods
}

type CustomResponseKeyValue struct {
	Key   string
	Value string
}

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

type DBProxyFilter interface {
	RequestCallback(query string, sessionID string) (CustomRequestActionInterface, error)
	ResponseCallback(sessionID string, err error)
}

type DBProxyInterface interface {
	SetCallbacks(requestCallback RequestQueryFilterCallback, responseCallback ResponseFilterCallback)
	SetFilter(filterObj DBProxyFilter)
	SetLoggers(t *log.Logger, e *log.Logger)
	Init() error
	Run() error // this function should start new goroutine
	IsStopped() bool
	WaitStop()
	Stop() error
}

type RequestQueryFilterCallback func(query string, sessionID string) (CustomRequestActionInterface, error)

type ResponseFilterCallback func(sessionID string, err error)