func()

in spark/client/conf.go [41:56]


func (r runtimeConfig) GetAll(ctx context.Context) (map[string]string, error) {
	req := &proto.ConfigRequest_GetAll{}
	operation := &proto.ConfigRequest_Operation_GetAll{GetAll: req}
	op := &proto.ConfigRequest_Operation{OpType: operation}
	resp, err := (*r.client).Config(ctx, op)
	if err != nil {
		return nil, err
	}
	m := make(map[string]string, 0)
	for _, k := range resp.GetPairs() {
		if k.Value != nil {
			m[k.Key] = *k.Value
		}
	}
	return m, nil
}