api

package

Go to main page

Versions in this module

v0

v0.0.2

Sep 5, 2019

Changes in this version

type DebugHandler

+ func (handler *DebugHandler) ShowShardSet(w http.ResponseWriter, r *http.Request)

type QueryHandler

+ func (handler *QueryHandler) HandleSQL(w http.ResponseWriter, r *http.Request)

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL