Versions in this module Expand all Collapse all v0 v0.0.1 Nov 27, 2018 Changes in this version + const ContentTypeHyperLogLog + const ContentTypeJSON + const ContentTypeUpsertBatch + var ErrBatchDoesNotExist = utils.APIError + var ErrColumnDeleted = utils.APIError + var ErrColumnDoesNotExist = utils.APIError + var ErrFailedToJSONMarshalResponseBody = utils.APIError + var ErrMissingParameter = utils.APIError + var ErrMsgDeletedColumn = "Bad request: column is already deleted" + var ErrMsgFailedToJSONMarshalResponseBody = "Failed to marshal the response body into json" + var ErrMsgFailedToReadRequestBody = "Bad request: failed to read request body" + var ErrMsgFailedToUnmarshalRequest = "Bad request: failed to unmarshal request body" + var ErrMsgMissingParameter = "Bad request: missing/invalid parameter" + var ErrMsgNonExistentColumn = "Bad request: column does not exist" + var ErrMsgNonExistentTable = "Bad request: table does not exist" + var ErrMsgNotImplemented = "Not implemented" + var ErrNotImplemented = utils.APIError + var ErrTableDoesNotExist = utils.APIError + func ReadRequest(r *http.Request, obj interface{}) error + func Respond(w http.ResponseWriter, obj interface{}) + func RespondBytesWithCode(w http.ResponseWriter, code int, bs []byte) + func RespondJSONObjectWithCode(w http.ResponseWriter, code int, obj interface{}) + func RespondWithBadRequest(w http.ResponseWriter, err error) + func RespondWithError(w http.ResponseWriter, err error) + func RespondWithJSONBytes(w http.ResponseWriter, jsonBytes []byte, err error) + func RespondWithJSONObject(w http.ResponseWriter, jsonObj interface{}) + type AQLRequest struct + Accept string + Body query.AQLRequest + Debug int + Device int + DeviceChoosingTimeout int + Origin string + Profiling string + Query string + Verbose int + type AQLResponse struct + Body query.AQLResponse + type AddColumnRequest struct + Body struct{ ... } + TableName string + type AddEnumCaseRequest struct + Body struct{ ... } + ColumnName string + TableName string + type AddEnumCaseResponse struct + Body []int + type AddTableRequest struct + Body metaCom.Table + type ArchiveRequest struct + Body struct{ ... } + type BackfillRequest struct + type ContentType string + type DataHandler struct + func NewDataHandler(memStore memstore.MemStore) *DataHandler + func (handler *DataHandler) PostData(w http.ResponseWriter, r *http.Request) + func (handler *DataHandler) Register(router *mux.Router, wrappers ...utils.HTTPHandlerWrapper) + type DebugHandler struct + func NewDebugHandler(memStore memstore.MemStore, metaStore metastore.MetaStore, ...) *DebugHandler + func (handler *DebugHandler) Archive(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) Backfill(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) EvictVectorParty(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) Health(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) HealthSwitch(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) ListRedoLogs(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) ListUpsertBatches(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) LoadVectorParty(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) LookupPrimaryKey(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) Purge(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) ReadBackfillQueueUpsertBatch(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) ReadUpsertBatch(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) Register(router *mux.Router) + func (handler *DebugHandler) ShowBatch(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) ShowDeviceStatus(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) ShowHostMemory(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) ShowJobStatus(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) ShowShardMeta(w http.ResponseWriter, r *http.Request) + func (handler *DebugHandler) Snapshot(w http.ResponseWriter, r *http.Request) + type DeleteColumnRequest struct + ColumnName string + TableName string + type DeleteTableRequest struct + TableName string + type EnumHandler struct + func NewEnumHandler(memStore memstore.MemStore, metastore metastore.MetaStore) *EnumHandler + func (handler *EnumHandler) AddEnumCase(w http.ResponseWriter, r *http.Request) + func (handler *EnumHandler) ListEnumCases(w http.ResponseWriter, r *http.Request) + func (handler *EnumHandler) Register(router *mux.Router, wrappers ...utils.HTTPHandlerWrapper) + type ErrorResponse struct + Body utils.APIError + type EvictVectorPartyRequest struct + type GetTableRequest struct + TableName string + type GetTableResponse struct + Body metaCom.Table + JSONBuffer []byte + type HLLQueryResponseWriter struct + func (w *HLLQueryResponseWriter) GetStatusCode() int + func (w *HLLQueryResponseWriter) ReportError(queryIndex int, table string, err error, statusCode int) + func (w *HLLQueryResponseWriter) ReportQueryContext(qc *query.AQLQueryContext) + func (w *HLLQueryResponseWriter) ReportResult(queryIndex int, qc *query.AQLQueryContext) + func (w *HLLQueryResponseWriter) Respond(rw http.ResponseWriter) + type HealthCheckHandler struct + func NewHealthCheckHandler() *HealthCheckHandler + func (handler *HealthCheckHandler) HealthCheck(w http.ResponseWriter, r *http.Request) + func (handler *HealthCheckHandler) Version(w http.ResponseWriter, r *http.Request) + type HealthSwitchRequest struct + OnOrOff string + type JSONQueryResponseWriter struct + func (w *JSONQueryResponseWriter) GetStatusCode() int + func (w *JSONQueryResponseWriter) ReportError(queryIndex int, table string, err error, statusCode int) + func (w *JSONQueryResponseWriter) ReportQueryContext(qc *query.AQLQueryContext) + func (w *JSONQueryResponseWriter) ReportResult(queryIndex int, qc *query.AQLQueryContext) + func (w *JSONQueryResponseWriter) Respond(rw http.ResponseWriter) + type ListEnumCasesRequest struct + ColumnName string + TableName string + type ListEnumCasesResponse struct + EnumCases []string + JSONBuffer []byte + type ListRedoLogsRequest struct + type ListRedoLogsResponse []string + type ListUpsertBatchesRequest struct + CreationTime int64 + type ListUpsertBatchesResponse []int64 + type LoadVectorPartyRequest struct + BatchID int + ColumnName string + type LookupPrimaryKeyRequest struct + Key string + type NoContentResponse struct + type PanicHandler struct + func WithPanicHandling(handler http.Handler) PanicHandler + func (handler PanicHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request) + type PostDataRequest struct + Body []byte + Shard int + TableName string + type PurgeRequest struct + Body struct{ ... } + type QueryHandler struct + func NewQueryHandler(memStore memstore.MemStore, cfg common.QueryConfig) *QueryHandler + func (handler *QueryHandler) GetDeviceManager() *query.DeviceManager + func (handler *QueryHandler) HandleAQL(w http.ResponseWriter, r *http.Request) + func (handler *QueryHandler) Register(router *mux.Router, wrappers ...utils.HTTPHandlerWrapper) + type QueryResponseWriter interface + GetStatusCode func() int + ReportError func(queryIndex int, table string, err error, statusCode int) + ReportQueryContext func(*query.AQLQueryContext) + ReportResult func(int, *query.AQLQueryContext) + Respond func(w http.ResponseWriter) + func NewHLLQueryResponseWriter() QueryResponseWriter + func NewJSONQueryResponseWriter(nQueries int) QueryResponseWriter + type ReadBackfillQueueUpsertBatchRequest struct + type ReadRedologUpsertBatchRequest struct + type ReadUpsertBatchRequest struct + Draw int + Length int + Offset int64 + Start int + type ReadUpsertBatchResponse struct + ColumnNames []string + Data [][]interface{} + Draw int + Error string + RecordsFiltered int + RecordsTotal int + type SchemaHandler struct + func NewSchemaHandler(metaStore metastore.MetaStore) *SchemaHandler + func (handler *SchemaHandler) AddColumn(w http.ResponseWriter, r *http.Request) + func (handler *SchemaHandler) AddTable(w http.ResponseWriter, r *http.Request) + func (handler *SchemaHandler) DeleteColumn(w http.ResponseWriter, r *http.Request) + func (handler *SchemaHandler) DeleteTable(w http.ResponseWriter, r *http.Request) + func (handler *SchemaHandler) GetTable(w http.ResponseWriter, r *http.Request) + func (handler *SchemaHandler) ListTables(w http.ResponseWriter, r *http.Request) + func (handler *SchemaHandler) Register(router *mux.Router, wrappers ...utils.HTTPHandlerWrapper) + func (handler *SchemaHandler) RegisterForDebug(router *mux.Router, wrappers ...utils.HTTPHandlerWrapper) + func (handler *SchemaHandler) UpdateColumn(w http.ResponseWriter, r *http.Request) + func (handler *SchemaHandler) UpdateTableConfig(w http.ResponseWriter, r *http.Request) + type ShardRequest struct + ShardID int + TableName string + type ShowBatchRequest struct + BatchID int + NumRows int + StartRow int + type ShowBatchResponse struct + Body struct{ ... } + type ShowJobStatusRequest struct + JobType string + type ShowShardMetaRequest struct + type SnapshotRequest struct + type StringArrayResponse struct + Body []string + func NewStringArrayResponse() StringArrayResponse + type UpdateColumnRequest struct + Body metaCom.ColumnConfig + ColumnName string + TableName string + type UpdateTableConfigRequest struct + Body metaCom.TableConfig + TableName string
Go to main page