grpc

type Error struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

type PingReq struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

type PingRes struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

type PrepareSeriesReq struct {
	Series []libtsdb.EmptySeries `protobuf:"bytes,1,rep,name=series" json:"series"`
}

type PrepareSeriesRes struct {
	Series []uint64 `protobuf:"varint,1,rep,packed,name=series" json:"series,omitempty"`
}

type PreparedPointDouble struct {
	Id uint64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	T  int64   `protobuf:"varint,2,opt,name=T,proto3" json:"T,omitempty"`
	V  float64 `protobuf:"fixed64,3,opt,name=V,proto3" json:"V,omitempty"`
}

type PreparedPointInt struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	T  int64  `protobuf:"varint,2,opt,name=T,proto3" json:"T,omitempty"`
	V  int64  `protobuf:"varint,3,opt,name=V,proto3" json:"V,omitempty"`
}

type WritePointsReq struct {
	Int    []libtsdb.PointIntTagged    `protobuf:"bytes,1,rep,name=int" json:"int"`
	Double []libtsdb.PointDoubleTagged `protobuf:"bytes,2,rep,name=double" json:"double"`
}

type WritePointsRes struct {
	Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

type WritePreparedPointsReq struct {
	Int    []PreparedPointInt    `protobuf:"bytes,1,rep,name=int" json:"int"`
	Double []PreparedPointDouble `protobuf:"bytes,2,rep,name=double" json:"double"`
}

type WritePreparedPointsRes struct {
	Error Error `protobuf:"bytes,1,opt,name=error" json:"error"`
}

type WritePreparedSeriesColumnarReq struct {
}

type WritePreparedSeriesColumnarRes struct {
	Error Error `protobuf:"bytes,1,opt,name=error" json:"error"`
}

type WritePreparedSeriesReq struct {
}

type WritePreparedSeriesRes struct {
	Error Error `protobuf:"bytes,1,opt,name=error" json:"error"`
}

type WriteSeriesReq struct {
	Int    []libtsdb.SeriesIntTagged    `protobuf:"bytes,1,rep,name=int" json:"int"`
	Double []libtsdb.SeriesDoubleTagged `protobuf:"bytes,2,rep,name=double" json:"double"`
}

type WriteSeriesRes struct {
	Error Error `protobuf:"bytes,1,opt,name=error" json:"error"`
}

type XephonkClient interface {
	Ping(ctx context.Context, in *PingReq, opts ...grpc1.CallOption) (*PingRes, error)
	// WritePoints is the most verbose one, but requires least effort on client side, just stream in point with tag
	WritePoints(ctx context.Context, in *WritePointsReq, opts ...grpc1.CallOption) (*WritePointsRes, error)
	// WriteSereis groups points of same series together to reduce cost of duplicating meta
	WriteSeries(ctx context.Context, in *WriteSeriesReq, opts ...grpc1.CallOption) (*WriteSeriesRes, error)
	// PrepareSeries gives each series a unique id, that can be used in this connection to omit passing full meta
	PrepareSeries(ctx context.Context, in *PrepareSeriesReq, opts ...grpc1.CallOption) (*PrepareSeriesRes, error)
	// WritePreparedPoints don't group points by series, but only prepared id is needed, not need to pass full meta
	WritePreparedPoints(ctx context.Context, in *WritePreparedPointsReq, opts ...grpc1.CallOption) (*WritePreparedPointsRes, error)
	// WritePreparedSeries not only use id for series, but also group points by series
	WritePreparedSeries(ctx context.Context, in *WritePreparedSeriesReq, opts ...grpc1.CallOption) (*WritePreparedSeriesRes, error)
	// WritePreparedSeriesColumnar use columnar format so points in one series can be compressed by protobuf
	WritePreparedSeriesColumnar(ctx context.Context, in *WritePreparedSeriesColumnarReq, opts ...grpc1.CallOption) (*WritePreparedSeriesColumnarRes, error)
}

type XephonkServer interface {
	Ping(context.Context, *PingReq) (*PingRes, error)
	// WritePoints is the most verbose one, but requires least effort on client side, just stream in point with tag
	WritePoints(context.Context, *WritePointsReq) (*WritePointsRes, error)
	// WriteSereis groups points of same series together to reduce cost of duplicating meta
	WriteSeries(context.Context, *WriteSeriesReq) (*WriteSeriesRes, error)
	// PrepareSeries gives each series a unique id, that can be used in this connection to omit passing full meta
	PrepareSeries(context.Context, *PrepareSeriesReq) (*PrepareSeriesRes, error)
	// WritePreparedPoints don't group points by series, but only prepared id is needed, not need to pass full meta
	WritePreparedPoints(context.Context, *WritePreparedPointsReq) (*WritePreparedPointsRes, error)
	// WritePreparedSeries not only use id for series, but also group points by series
	WritePreparedSeries(context.Context, *WritePreparedSeriesReq) (*WritePreparedSeriesRes, error)
	// WritePreparedSeriesColumnar use columnar format so points in one series can be compressed by protobuf
	WritePreparedSeriesColumnar(context.Context, *WritePreparedSeriesColumnarReq) (*WritePreparedSeriesColumnarRes, error)
}