|
@@ -10,7 +10,6 @@ import (
|
|
|
|
|
|
|
|
type SegmentWriter interface {
|
|
type SegmentWriter interface {
|
|
|
Write(seg Segment) error
|
|
Write(seg Segment) error
|
|
|
- Release()
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
type SimpleSegmentWriter struct {
|
|
type SimpleSegmentWriter struct {
|
|
@@ -37,10 +36,6 @@ func (w *SimpleSegmentWriter) Write(seg Segment) error {
|
|
|
return err
|
|
return err
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-func (w *SimpleSegmentWriter) Release() {
|
|
|
|
|
- w.buffer.Release()
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
type RetryableWriter struct {
|
|
type RetryableWriter struct {
|
|
|
writer SegmentWriter
|
|
writer SegmentWriter
|
|
|
}
|
|
}
|
|
@@ -56,7 +51,3 @@ func (w *RetryableWriter) Write(seg Segment) error {
|
|
|
return w.writer.Write(seg)
|
|
return w.writer.Write(seg)
|
|
|
})
|
|
})
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
-func (w *RetryableWriter) Release() {
|
|
|
|
|
- w.writer.Release()
|
|
|
|
|
-}
|
|
|