func()

in server/datasource/mongo/kv/kv_dao.go [669:694]


func (s *Dao) GetByKey(ctx context.Context, key, project, domain string, options ...datasource.FindOption) ([]*model.KVDoc, error) {
	opts := datasource.FindOptions{}
	for _, o := range options {
		o(&opts)
	}
	if opts.LabelFormat != "" {
		kvs, err := findKVByLabel(ctx, domain, opts.LabelFormat, key, project)
		if err != nil {
			return nil, err
		}
		return kvs, nil
	}
	kvs, err := s.List(ctx, domain, project,
		datasource.WithExactLabels(),
		datasource.WithLabels(opts.Labels),
		datasource.WithKey(key))
	if err != nil {
		openlog.Error("check kv exist: " + err.Error())
		return nil, err
	}
	if len(kvs.Data) != 1 {
		return nil, datasource.ErrTooMany
	}

	return kvs.Data, nil
}