types

type AuthRequest struct {
	SessionTicket // this will be empty 1st request, 2nd request of the auth handshake it will validate
	Nonce         string
	Signature     string
}

type AuthResponse struct {
	Error         *RpcError
	SessionId     int
	SessionSecret string
}

type Endpoint string

type NoOpRequest struct {
	SessionTicket
}

type NoOpResponse struct {
	Error *RpcError
}

type ReadRequest struct {
	SessionTicket
	Queries []ReadSeriesRequest
}

type ReadResponse struct {
	Error   *RpcError
	Results map[uint64]map[uint64]float64 // map series id => timestamp => value
}

type ReadSeriesRequest struct {
	From uint64
	To   uint64
	SeriesIdentifier
}

type RpcError string

type SeriesCreateIdentifier uint64 // xxhash64 of uuid bytes

type SeriesCreateMetadata struct {
	SeriesMetadata
	SeriesCreateIdentifier
}

type SeriesIdentifier struct {
	Namespace int
	Id        uint64
}

type SeriesMetadata struct {
	Namespace int
	Name      string
	Tags      []string
	Ttl       uint // relative time in seconds
}

type SeriesMetadataRequest struct {
	// @todo support multiple series at once, will increase performance of first flushes a lot (e.g. batch size of 1000 will have 1000 round trips over TCP, have seen easily 30 seconds for that)
	SeriesCreateMetadata
	SessionTicket
}

type SeriesMetadataResponse struct {
	Id uint64
	SeriesCreateIdentifier
	Error *RpcError
	New   bool
}

type SessionTicket struct {
	Id        int // this identifies the session
	Nonce     int // randomly generated by client
	Signature int // murmur hash truncated to int of the nonce with the secure session token
}

type WriteRequest struct {
	SessionTicket
	Series []WriteSeriesRequest
}

type WriteResponse struct {
	Num   int
	Error *RpcError
}

type WriteSeriesRequest struct {
	SeriesIdentifier
	Times  []uint64
	Values []float64
}