# README
services/data/
This service handles data-plane functionality like reading data, queuing data writes, serving subscriptions and running the background data writing worker.
It's used by the data-server and data-worker startables.
# Packages
No description provided by the author
# Functions
CursorFromBytes creates (and validates) a Cursor from the return value of cursor.GetBytes().
New returns a new data service instance.
NewCursor builds a new Cursor.
# Constants
IndexCursorType represents an IndexService cursor.
LogCursorType represents a LogService cursor.
WarehouseCursorType represents a WarehouseCursorType cursor.
# Structs
Error represents a generalized GRPC and HTTP error.
PingRequest is a request to HandlePing.
PingResponse is a result from HandlePing.
PollWarehouseRequest is a request to HandlePollWarehouse.
PollWarehouseResponse is a result from HandlePollWarehouse.
QueryIndexRequest is a request to HandleQueryIndex.
QueryIndexResponse is a result from HandleQueryIndex.
QueryLogRequest is a request to HandleQueryLog.
QueryLogResponse is a result from HandleQueryLog.
QueryWarehouseRequest is a request to HandleQueryWarehouse.
QueryWarehouseResponse is a result from HandleQueryWarehouse.
ReadRequest is a request to HandleRead.
ReadResponse is a result from HandleRead.
Service implements the data-plane functionality for handling requests (in a protocol-agnostic way used by the http and grpc interfaces), and for processing records in the background.
SubscribeRequest is a request to HandleSubscribe.
SubscribeResponse is a result from HandleSubscribe.
SubscriptionMessage encapsulates a subscription update dispatched by a Broker.
WarehouseJob represents a warehouse query job.
WriteRecords represents records to write, either as parsed json or protocol buffers.
WriteRequest is a request to HandleWrite.
WriteResponse is a result from HandleWrite.
# Type aliases
Cursor wraps an underlying engine cursor with cursor type and UUID.
CursorType represents the engine service of the underlying cursor (payload).