func()

in datahub/connector.go [103:124]

• 20 lines of code
• 7 McCabe index (conditional complexity)

func (pc *PartitionConfig) MarshalJSON() ([]byte, error) {
	if pc == nil || len(pc.ConfigMap) == 0 {
		return nil, nil
	}
	buf := &bytes.Buffer{}
	buf.Write([]byte{'{'})

	length := len(pc.ConfigMap)
	for i, m := range pc.ConfigMap {
		for k, v := range m {
			if _, err := fmt.Fprintf(buf, "\"%s\":\"%s\"", k, v); err != nil {
				return nil, fmt.Errorf("partition config is invalid")
			}
		}
		if i < length-1 {
			buf.WriteByte(',')
		}
	}
	buf.WriteByte('}')

	return buf.Bytes(), nil
}