proxy_http

type Config struct {
	Elastic struct {
		EndPoint   string `json:"endpoint,omitempty"`
		User       string `json:"user,omitempty"`
		Password   string `json:"password,omitempty"`
		ESPassword string `json:"esPassword,omitempty"`
		IgnoreCert bool   `json:"ignoreCert,omitempty"`
	} `json:"elastic,omitempty"`
	Sneller            configSneller            `json:"sneller,omitempty"`
	Mapping            map[string]*mappingEntry `json:"mapping"`
	CompareWithElastic bool                     `json:"compareWithElastic,omitempty"`
}

type DummyCache struct{}

type ElasticMapping = elastic_proxy.ElasticMapping

type HandlerContext struct {
	Request *http.Request
	Writer  http.ResponseWriter
	Config  *Config
	Logging *Logging
	Client  *http.Client
	Mapping *mappingEntry // currently selected mapping for an index
	Cache   MappingCache

	// function performing verbose logging
	VerboseLog func(string, ...any)

	// Flag indicating we're using verbose logging;
	// provided in case some logging activities might
	// cost more than a single VerboseLog call.
	Verbose bool

	Memcache struct {
		// Optional memcache client
		Client *memcache.Client
		// The ID used to distinguish ElasticProxy instances
		TenantID string
		// A string used to create a crypto key
		Secret string
		// Item expiration timeout
		ExpirationTime int
	}
}

type LogDetail struct {
	LogRequest       bool
	LogQueryParams   bool
	LogSQL           bool
	LogSnellerResult bool
	LogPreprocessed  bool
	LogResult        bool
}

type Logging struct {
	Revision       string                       `json:"revision"`
	SourceIP       string                       `json:"sourceIp"`
	TenantID       string                       `json:"tenantId,omitempty"`
	QueryID        string                       `json:"queryId"`
	Start          time.Time                    `json:"start"`
	Index          string                       `json:"index"`
	Duration       time.Duration                `json:"duration"`
	HttpStatusCode int                          `json:"httpStatusCode"`
	Sneller        *SnellerLogging              `json:"sneller,omitempty"`
	Request        map[string]any               `json:"request,omitempty"`
	QueryParams    url.Values                   `json:"queryParameters,omitempty"`
	SQL            string                       `json:"sql,omitempty"`
	SnellerResult  map[string]any               `json:"snellerResult,omitempty"`
	Preprocessed   map[string]any               `json:"preprocessed,omitempty"`
	Result         *elastic_proxy.ElasticResult `json:"result,omitempty"`
	ElasticResult  map[string]any               `json:"elasticResult,omitempty"`
	ElasticDiff    string                       `json:"diff,omitempty"`
}

type MappingCache interface {
	// Store saves ElasticMapping entry for given database and table.
	Store(idxName string, mapping *ElasticMapping) error

	// Fetch loads ElasticMapping entry for given database and table.
	// It returns nil, false if no mapping was found.
	Fetch(idxName string) (*ElasticMapping, error)
}

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

type SnellerLogging struct {
	EndPoint     string               `json:"endpoint"`
	Sources      []mappingEntrySource `json:"sources"`
	TokenLast4   string               `json:"tokenLast4"`
	CacheHits    int                  `json:"cacheHits,omitempty"`
	CacheMisses  int                  `json:"cacheMisses,omitempty"`
	BytesScanned int                  `json:"bytesScanned,omitempty"`
}