Method Write

backup/run.go:445–481

(buf *z.Buffer)

}

func (bw *bufWriter) Write(buf *z.Buffer) error {
	kv := &bpb.KV{}
	err := buf.SliceIterate(func(s []byte) error {
		kv.Reset()
		if err := proto.Unmarshal(s, kv); err != nil {
			return fmt.Errorf("processKvBuf failed to unmarshal kv: %w", err)
		}
		pk, err := x.Parse(kv.Key)
		if err != nil {
			return fmt.Errorf("processKvBuf failed to parse key: %w", err)
		}
		if pk.Attr == "_predicate_" {
			return nil
		}
		if pk.IsSchema() || pk.IsType() {
			return exportSchema(bw.writers, kv.Value, pk)
		}
		if pk.IsData() {
			pl := &pb.PostingList{}
			if err := proto.Unmarshal(kv.Value, pl); err != nil {
				return fmt.Errorf("processKvBuf failed to Unmarshal pl: %w", err)
			}
			l := posting.NewList(kv.Key, pl, kv.Version)
			kvList, err := worker.ToExportKvList(pk, l, bw.req)
			if err != nil {
				return fmt.Errorf("processKvBuf failed to export: %w", err)
			}
			if len(kvList.Kv) == 0 {
				return nil
			}
			exportKv := kvList.Kv[0]
			return worker.WriteExport(bw.writers, exportKv, bw.req.Format)
		}
		return nil
	})
	return fmt.Errorf("bufWriter failed to write: %w", err)
}

func runExportBackup() error {
	keys, err := x.GetEncAclKeys(ExportBackup.Conf)