Write implements backend.Writer
(ctx context.Context, name string, keypath backend.KeyPath, data io.Reader, _ int64, _ *backend.CacheInfo)
| 116 | |
| 117 | // Write implements backend.Writer |
| 118 | func (rw *Azure) Write(ctx context.Context, name string, keypath backend.KeyPath, data io.Reader, _ int64, _ *backend.CacheInfo) error { |
| 119 | keypath = backend.KeyPathWithPrefix(keypath, rw.cfg.Prefix) |
| 120 | |
| 121 | derivedCtx, span := tracer.Start(ctx, "azure.Write") |
| 122 | defer span.End() |
| 123 | |
| 124 | return rw.writer(derivedCtx, bufio.NewReader(data), backend.ObjectFileName(keypath, name)) |
| 125 | } |
| 126 | |
| 127 | // Append implements backend.Writer |
| 128 | func (rw *Azure) Append(ctx context.Context, name string, keypath backend.KeyPath, tracker backend.AppendTracker, buffer []byte) (backend.AppendTracker, error) { |
no test coverage detected