Function write

pkg/util/users/tenant_deletion_mark.go:85–92

(ctx context.Context, bkt objstore.Bucket, markerFile string, mark *TenantDeletionMark)

}

func write(ctx context.Context, bkt objstore.Bucket, markerFile string, mark *TenantDeletionMark) error {
	data, err := json.Marshal(mark)
	if err != nil {
		return errors.Wrap(err, "serialize tenant deletion mark")
	}

	return errors.Wrap(bkt.Upload(ctx, markerFile, bytes.NewReader(data)), "upload tenant deletion mark")
}

func read(ctx context.Context, bkt objstore.BucketReader, markerFile string, logger log.Logger) (*TenantDeletionMark, error) {
	r, err := bkt.Get(ctx, markerFile)