(ctx context.Context)
| 124 | } |
| 125 | |
| 126 | func (f *fanout) Appender(ctx context.Context) Appender { |
| 127 | primary := f.primary.Appender(ctx) |
| 128 | secondaries := make([]Appender, 0, len(f.secondaries)) |
| 129 | for _, storage := range f.secondaries { |
| 130 | secondaries = append(secondaries, storage.Appender(ctx)) |
| 131 | } |
| 132 | return &fanoutAppender{ |
| 133 | logger: f.logger, |
| 134 | primary: primary, |
| 135 | secondaries: secondaries, |
| 136 | } |
| 137 | } |
| 138 | |
| 139 | func (f *fanout) AppenderV2(ctx context.Context) AppenderV2 { |
| 140 | primary := f.primary.AppenderV2(ctx) |