Packages

dproto

0.2.0
0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.1 0.4.0 0.3.1 0.3.0 0.2.8 0.2.7 0.2.6 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.25 0.1.24 0.1.23 0.1.22 0.1.21 0.1.20 0.1.19 0.1.18 0.1.17 0.1.16 0.1.15 0.1.14 0.1.13 0.1.12 0.1.11 0.1.10 0.1.9 0.1.8 0.1.7

Protocols for dalmatinerdb

Current section

Files

Jump to
Readme
39 Versions
3 Dependencies
Dependants
Files
Activity
dproto src dproto_udp.erl
Raw

src/dproto_udp.erl 

-module(dproto_udp).

-include_lib("mmath/include/mmath.hrl").

-include("dproto.hrl").



-export([encode_header/1, encode_points/3]).



-ignore_xref([encode_header/1, encode_points/3]).



encode_header(Bucket) ->

    <<?PUT, (byte_size(Bucket)):?BUCKET_SS/?SIZE_TYPE,

      Bucket/binary>>.



encode_points(Metric, Time, Points) when is_list(Points) ->

    encode_points(Metric, Time, mmath_bin:from_list(Points));



encode_points(Metric, Time, Points) when is_binary(Metric),

                                         is_binary(Points) ->

    <<Time:?TIME_SIZE/?SIZE_TYPE,

      (byte_size(Metric)):?METRIC_SS/?SIZE_TYPE, Metric/binary,

      (byte_size(Points)):?DATA_SS/?SIZE_TYPE, Points/binary>>.