Method Write

tempodb/backend/gcs/gcs.go:117–141

Write implements backend.Writer

(ctx context.Context, name string, keypath backend.KeyPath, data io.Reader, _ int64, _ *backend.CacheInfo)

// Write implements backend.Writer
func (rw *readerWriter) Write(ctx context.Context, name string, keypath backend.KeyPath, data io.Reader, _ int64, _ *backend.CacheInfo) error {
	keypath = backend.KeyPathWithPrefix(keypath, rw.cfg.Prefix)
	derivedCtx, span := tracer.Start(ctx, "gcs.Write")
	defer span.End()

	span.SetAttributes(attribute.String("object", name))

	w := rw.writer(derivedCtx, backend.ObjectFileName(keypath, name), nil)

	written, err := io.Copy(w, data)
	if err != nil {
		w.Close()
		span.RecordError(err)
		return fmt.Errorf("failed to write: %w", err)
	}

	err = w.Close()
	if err != nil {
		return fmt.Errorf("failed to close: %w", err)
	}

	level.Debug(rw.logger).Log("msg", "object uploaded to gcs", "objectName", backend.ObjectFileName(keypath, name), "size", written)

	return nil
}

// Append implements backend.Writer
func (rw *readerWriter) Append(ctx context.Context, name string, keypath backend.KeyPath, tracker backend.AppendTracker, buffer []byte) (backend.AppendTracker, error) {