type Rrd struct {
	D					[][]*float64	`xyzdb:"D" bson:"D" json:"D"`
	R					[][]*float64	`xyzdb:"R" bson:"R" json:"R"`
	CurrentAvgCount		int64			`xyzdb:"CurrentAvgCount" bson:"CurrentAvgCount" json:"CurrentAvgCount"`
	FirstUpdateTs		*time.Time		`xyzdb:"FirstUpdateTs" bson:"FirstUpdateTs" json:"FirstUpdateTs"`
	LastUpdateDataPoint	[]*float64		`xyzdb:"LastUpdateDataPoint" bson:"LastUpdateDataPoint" json:"LastUpdateDataPoint"`
	LastUpdate			time.Time		`xyzdb:"LastUpdate" bson:"LastUpdate" json:"LastUpdate"`
	MinimumDataPoints	uint64			`xyzdb:"MinimumDataPoints" bson:"MinimumDataPoints" json:"MinimumDataPoints"`
	Interval			time.Duration	`xyzdb:"Interval" bson:"Interval" json:"Interval"`
	TotalSteps			uint64			`xyzdb:"TotalSteps" bson:"TotalSteps" json:"TotalSteps"`
	DataType			uint8			`xyzdb:"DataType" bson:"DataType" json:"DataType"`
	Debug				bool			`json:"-"`
}

// 24 hours with 5 minute interval (24 * 60 / 5 samples)
var rrd_5m rrd.Rrd
rrd_5m.Interval = time.Minute * 5
rrd_5m.TotalSteps = 24 * 60 / 5
rrd_5m.DataType = rrd.Gauge

rrd.Update(rrd.GetUpdateValues(434, 700), &rrd_5m)

// 30 days with 1 hour interval (30 * 24 samples)
var rrd_1h rrd.Rrd
rrd_1h.Interval = time.Hour
rrd_1hTotalSteps = 30 * 24
rrd_1h.DataType = rrd.Gauge

rrd.Update(rrd.GetUpdateValues(434, 700), &rrd_1h)

// 365 days with 1 day interval (365 samples)
var rrd_1d rrd.Rrd
rrd_1d.Interval = time.Hour * 24
rrd_1dTotalSteps = 365
rrd_1d.DataType = rrd.Gauge

rrd.Update(rrd.GetUpdateValues(434, 700), &rrd_1d)

// 5 seconds with a 1 second interval (5 samples)
var rrd_short Rrd
rrd_short.Interval = time.Second
rrd_short.TotalSteps = 5
rrd_short.DataType = rrd.Counter

// 60 seconds with a 1 second interval (60 samples)
var rrd_long Rrd
rrd_long.Interval = time.Second
rrd_long.TotalSteps = 60
rrd_long.DataType = rrd.Counter

rrd.Update(rrd.GetUpdateValues(40), &rrd_short)
rrd.Update(rrd.GetUpdateValues(40), &rrd_long)

// get average of all rrd
var avg = rrd.Avg(0, &rrd_short, &rrd_long)

type Interpolation struct {
		// at least 2 values that are sequential, regardless of direction
		// each value is expected to be of an interval with an equal duration
		//	BaseRange 0,100			Input 50			=OutputRatio .5
		//	BaseRange 0,20,100		Input 50			=OutputRatio .6875
		BaseRange					[]float64
		// exactly 2 values
		OutputRange					[]float64
		Input						float64
}

type TokenQueue struct {
	// the sum of each Token.Size allowed per second
	RatePerSecond		float64
	Tokens				[]*Token
	// rrd.Working with QueueToken and UnqueueToken
	// rrd.Instant with WaitToCompleteToken
	Type				uint8
	RrdPointer			*Rrd
	sync.RWMutex
}

type Token struct {
	// the size of this token, write size in bytes for example
	Size				uint64
	Pending				bool
	// the lowest Prio proceeds first
	// this allows allocation and order to be handled conceptually at each Token
	Prio				uint64
	Time				time.Time
}

// create a rrd.TokenQueue that limits disk writing at 200MB/s
var token_queue_pointer *rrd.TokenQueue
rrd.SetTokenQueueLimiter(&token_queue_pointer, 200 * 1000 * 1000, rrd.Working)

// write 2000MB to disk from 50,000 goroutines
var count = 0
for {

    if (count == 50000) {
        break
    }

    go func() {

        var write_size uint64 = 40000

        var data_to_write = make([]byte, write_size)

        // Prio can be set, try 1 with large files and 0 with the last write of any file
        // MaxWait can be set and is used regardless of Prio
        var token_pointer = rrd.QueueToken(&token_queue_pointer, write_size, 0, nil)

        // write to disk

        rrd.UnqueueToken(token_queue_pointer, token_pointer)

    }()

    count += 1

}

// create a rrd.TokenQueue that limits data sent to a TCP socket at 400 KB/s
var token_queue_pointer *rrd.TokenQueue
rrd.SetTokenQueueLimiter(&token_queue_pointer, 400 * 1000, rrd.Instant)

for {

    // send 2MB each iteration
    var send_size uint64 = 1000 * 1000 * 2

    var data_to_send = make([]byte, send_size)

    rrd.WaitToken(token_queue_pointer, write_size, 0, nil)

    // this is `instant` enough to work with rrd.Instant
    socket.Write(data_to_send)

}