decoder

type DecodedAggregation struct {
	Agg *schema.TlogAggregation
	Err error
}

type Decoder struct {
	// contains filtered or unexported fields
}

type LimitBySequence struct {
	// contains filtered or unexported fields
}

type LimitByTimestamp struct {
	// contains filtered or unexported fields
}

type Limiter interface {

	// StartAgg returns true if it is the start of the
	// aggregation we want to decode
	StartAgg(*schema.TlogAggregation, schema.TlogBlock_List) bool

	// EndAgg returns true if it is the end  of the
	// aggregation we want to decode
	EndAgg(*schema.TlogAggregation, schema.TlogBlock_List) bool

	// StartBlock returns true if it is the start of block we want to decode
	StartBlock(schema.TlogBlock) bool

	// EndBlock returns true if it is the end of block we want to decode
	EndBlock(schema.TlogBlock) bool
}